Anoop Nair

Figured out the issue.

The 2nd approach works. The issue was with my invocation of the deleteAllQueuedMessages message. The method takes a boolean argument which indicates the messages should be moved to the Exception Destination. I was not passing this argument !!!

I corrected the implementation as below and it works now.
connection.invoke(objName, "deleteAllQueuedMessages", new Object[]{false}, new String[]{"java.lang.Boolean"});

Hi All,

I want to delete all the messages in a queue configured in Websphere 8.5 SIB. Below are two approaches I tried, but none of them seem to be working and each throws a different exception. Can someone please advise on what is the correct way to achieve this.

Approach 1
MBeanServerConnection connection = getServerConnection(); connection.invoke(new ObjectName("WebSphere:*,type=SIBQueuePoint,name=jms.queue.MY_QUEUE"), "deleteAllQueuedMessages", null, null);
This approach throws the below exception.

javax.management.InstanceNotFoundException: WebSphere:type=SIBQueuePoint,name=jms.queue.MY_QUEUE

Approach 2
MBeanServerConnection connection = getServerConnection(); ObjectName objQueue = new ObjectName(WAS85_RESOURCE_URL + ",type=SIBQueuePoint"); Set<ObjectName> objNames = connection.queryNames(objQueue, null); for(ObjectName objName: objNames) { String qName = connection.getAttribute(objName,"identifier").toString(); if(qName.equals("jms.queue.MY_QUEUE")) { connection.invoke(objName, "deleteAllQueuedMessages", null, null); } }
This approach throws the below exception

javax.management.ReflectionException: Target method not found: com.ibm.ws.sib.admin.impl.JsQueuePoint.deleteAllQueuedMessages

Solved the issue. I wrote a message reciever for the queue with messageId as the selector.

QueueReceiver receiver = ((QueueSession) session).createReceiver(queue, "JMSMessageID='"+messageId+"'"); for(;;) { Message message = receiver.receive(); if(messageId.equals(message.getJMSMessageID())) { result = MSG_DEL_SUCCESS.replace("${msgId}", messageId); break; } }

I am writing an API to delete messages from Jboss service integration bus. I need to provide methods for deleting individual messages and also all the messages (purge) in the queue.

I tried finding the list of operations available on a queue using JMX. Below is the code I used for getting the list of operations. It has an operation "removeAllMessages" which would delete all the messages in the queue. However, I did not find any operation that would help me delete individual messages from the queue. Also, I found the QueueBrowser API of JMX. But the specification says that the class does not delete messages from the queue.

MBeanServerConnection connection = getConnection(); ObjectName queueObjName = getObjNameforQueue(myQueue); MBeanInfo mbeanInfo = connection.getMBeanInfo(objName); MBeanOperationInfo[] ops = mbeanInfo.getOperations(); for(MBeanOperationInfo op: ops) { System.out.println("Operation Name: "+op.getName()); }
Please let me know how I can delete individual messages from the queue.

Thanks Mark.

That works perfectly now.

Although, I still do not understand why it was throwing an exception when the aop config was present in the same file.

Hi All,

I have a Spring 3.0 MVC application that works fine. I want to introduce AOP in this application. However on doing this I am getting the below exception.

org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'org.springframework.web.servlet.mvc. annotation.DefaultAnnotationHandlerMapping#0': Initialization of bean failed; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'org.springframework.web.servlet.handler.MappedInterceptor#0': Initialization of bean failed; nested exception is org.springframework.aop.framework.AopConfigException: Could not generate CGLIB subclass of class [class org.springframework.web.servlet.handler.MappedInterceptor]: Common causes of this problem include using a final class or a non-visible class; nested exception is java.lang.IllegalArgumentException: Cannot subclass final class class org.springframework.web.servlet.handler.MappedInterceptor

Below is the application code:

Controller
package com.myapp.controller; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.ui.Model; import org.springframework.web.bind.annotation.RequestMapping; import com.myapp.service.IMyService; @Controller public class MyController { @Autowired private IMyService service; @RequestMapping(value = "/") public String myAction(Model model) { service.showMessage(); return "home"; } }

Model interface and implementation:
package com.myapp.service; public interface IMyService { public void showMessage(); } ---------------------------------- package com.myapp.service; import org.springframework.stereotype.Component; @Component public class MyServiceImpl implements IMyService { @Override public void showMessage() { System.out.println("in impl... hello world"); } }

package com.myapp.aspects; import org.aspectj.lang.JoinPoint; import org.aspectj.lang.annotation.Aspect; import org.aspectj.lang.annotation.Before; import org.aspectj.lang.annotation.Pointcut; @Component @Aspect public class MyAspect { @Pointcut("execution(* com.myapp.service.*.*(..))") public void myPointCut() { } @Before("myPointCut()") public void profile(JoinPoint jp) throws Throwable { System.out.println("Going to call the method... "+jp.getSignature().getName()); } }

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:context="http://www.springframework.org/schema/context" xmlns:aop="http://www.springframework.org/schema/aop" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd"> <context:component-scan base-package="com.myapp"/> <mvc:annotation-driven/> <context:annotation-config/> <aop:aspectj-autoproxy /> </beans>


Can someone please point out what I am doing wrong with this ??

Hi All,

I have a web service client. I am using Axis 1.4.

I want to setup the connection timeout interval in my client. Can someone tell me how I can do this?

Also, I want to handle the timeout exception that is thrown so that I can redirect it to an appropriate handler.

Hi All,

I have a webpage in which there is a "Save" button, which is supposed to save the entire page in PDF format.
The webpage has images, text and also CSS.

I tried using flying saucer and iText. However when using this, the background images (done via CSS) are not coming in the PDF file.

Below is the code I am using. Is there a better way to do this where the entire page can directly be converted to PDF format.

URL pageURL = new URL("http://localhost:8180/myApp/myPage.htm?"+queryStr); BufferedReader in = new BufferedReader(new InputStreamReader(pageURL.openStream())); BufferedWriter bw = new BufferedWriter(new FileWriter("myTempFile"+request.getSession().getId()+".html")); String inputLine; while ((inputLine = in.readLine()) != null) bw.write(inputLine); in.close(); bw.flush(); bw.close(); String inputFile = "myTempFile"+request.getSession().getId()+".html"; String url = new File(inputFile).toURI().toURL().toString(); String outputFile = "pdfSave.pdf"; OutputStream os = new FileOutputStream(outputFile); ITextRenderer renderer = new ITextRenderer(); renderer.setDocument(url); renderer.layout(); try { renderer.createPDF(os); } catch (DocumentException e) { e.printStackTrace(); }

Thanks Peter,

There was indeed a firewall issue. Seems like the IP and port combination was not open.

Personally, I would not mix the two methods, nor would I bind any server to 0.0.0.0 when using multiple IP address. In other words, I would either:

a) bind every server to 0.0.0.0 and use different ports
b) bind each server to its own distinct IP address (each using the same ports) - this option requires a separate physical IP address for each server

My requirement is that only one of the servers should be listening on both the IPs, the others shouldnt be. Could you please point me to some article so that I can understand this ?

When running DF2 with -b <IP2>, on stopping the server I get the following exception:

Exception in thread "main" javax.naming.NameNotFoundException: jmx not bound
at org.jnp.server.NamingServer.getBinding(NamingServer.java:581)
at org.jnp.server.NamingServer.getBinding(NamingServer.java:589)
at org.jnp.server.NamingServer.getObject(NamingServer.java:595)
at org.jnp.server.NamingServer.lookup(NamingServer.java:313)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at sun.rmi.server.UnicastServerRef.dispatch(UnicastServerRef.java:305)
at sun.rmi.transport.Transport$1.run(Transport.java:159)
at java.security.AccessController.doPrivileged(Native Method)
at sun.rmi.transport.Transport.serviceCall(Transport.java:155)
at sun.rmi.transport.tcp.TCPTransport.handleMessages(TCPTransport.java:535)
at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(TCPTransport.java:790)
at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(TCPTransport.java:649)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:619)
at sun.rmi.transport.StreamRemoteCall.exceptionReceivedFromServer(StreamRemoteCall.java:255)
at sun.rmi.transport.StreamRemoteCall.executeCall(StreamRemoteCall.java:233)
at sun.rmi.server.UnicastRef.invoke(UnicastRef.java:142)
at org.jnp.server.NamingServer_Stub.lookup(Unknown Source)
at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:667)
at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:627)
at javax.naming.InitialContext.lookup(InitialContext.java:392)
at org.jboss.Shutdown.main(Shutdown.java:214)

Thanks Jaikiran and Peter for your responses.

I am using JBoss AS 4.3 on Linux.

Three JBoss instances are running on the same system on different ports. The system has two IP addresses, IP1 and IP2. Ex. IP1 = 1.1.1.1 and IP2 = 2.2.2.2.

Instance1 is a clustered server (CL1). The binding 0.0.0.0 works with this one. The other two are instances of the default server (DF1 and DF2). The binding works for one of the default servers (DF1).

After starting DF2 when I do http://2.2.2.2:8080, the console doesnt come up. However, if I do http://1.1.1.1:8080 it comes up.

The server is started using run.sh command with the below arguments
-Djboss.server.log.dir
-Djboss.server.base.url
-Djboss.server.base.dir
-b 0.0.0.0

I am not able to figure out what could be the difference in the configuration of the two default servers.

I also tried running DF2 with -b IP2.
However, this also doesnt work. In this case the console doesnt come up on doing trying IP1 as well, which was expected.

Hi All,

I had previously posted here to know how I can make JBoss listen on two IPs.

I tried that and it worked. However, when I try the same thing on another JBoss instance it doesnt work.
The only difference I noted was that the first one was a clustered server whereas the second one is a default server.

Am I missing something here ?

Thanks Jaikiran.

I have made the server listen on 0.0.0.0 now.

Hi Jaikiran,

Thanks for your reply.

I tried this. But it overwrites the IP specified in bind.address.
And so it listens only on the IP specified by -b.

I tried setting the run parameter bind.address.
If I set it to 0.0.0.0, it works. But then it listens to all the IPs of the system. Run Parameters Explained

Is there a way to specify specific IP address ?