[JBoss AOP Users] - Re: Deploy AOP to jboss 5.1
by kgreenejpmc
Ok, after quite a bit of trial and error I finally got the aop to work. However, I have a question.
If I put my @JobFlow annotation on the onMessage method, the aop does not work. However, If I put the @JobFlow annotation on the processMessage method (which onMessage calls), the aop works. Does jboss suppress or ignore custom annotations on onMessage? If so, is there a way to enable them to work on onMessage?
| @MessageDriven(activationConfig = {
| @ActivationConfigProperty(propertyName="maxMessages", propertyValue="1"),
| @ActivationConfigProperty(propertyName="maxSession", propertyValue="3"),
| @ActivationConfigProperty(propertyName="dLQMaxResent", propertyValue="1"),
| @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
| @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/TestConsumer1")
| })
| @Clustered
| public class TestConsumer1 implements MessageListener {
|
|
|
|
| private static Logger log = Logger.getLogger(TestConsumer1.class);
|
| @Resource
| private MessageDrivenContext context;
|
|
|
| //put @JobFlow here does not work. The aop does not get called
| public void onMessage(Message msg) {
| log.info("Got message.");
|
|
| try
| {
| processMessage(msg);
| TextMessage txtMsg = (TextMessage)msg;
| String stagingPath = txtMsg.getText();
|
| log.info("FlowId: " + MessageProperties.getFlowId(msg));
| log.info("JobId: " + MessageProperties.getJobId(msg));
| log.info("PrevStageId: " + MessageProperties.getPrevStageId(msg));
|
| }
| catch (Exception e)
| {
| context.setRollbackOnly();
|
| }
|
|
| log.info("DONE!");
| }
|
|
| //putting @JobFlow here works and the aop is called
| @JobFlow
| public void processMessage(Message msg)
| {
| log.info("Running processMessage");
| }
|
| }
|
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4251632#4251632
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4251632
16 years, 8 months
[JBoss Messaging Users] - Deploying an MDB on a server started using the -b option.
by k.k.ramachandran
Hi,
I've got a simple EJB 3 style MDB. When I deploy it on a server started without the -b option i.e ./run.sh. It works fine. When I deploy it to a server started with the -b option ./run.sh -b <ip addr> I get the following errors :
| 14:12:48,538 DEBUG [NamingContext] Failed to connect to localhost:1099
| javax.naming.CommunicationException: Failed to connect to server localhost/127.0.0.1:1099 [Root exception is javax.naming.ServiceUnavailableException: Failed to connect to server localhost/127.0.0.1:1099 [Root exception is java.net.ConnectException: Connection refused]]
| at org.jnp.interfaces.NamingContext.getServer(NamingContext.java:331)
| at org.jnp.interfaces.NamingContext.checkRef(NamingContext.java:1696)
| at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:689)
| at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:682)
| at javax.naming.InitialContext.lookup(InitialContext.java:351)
| at org.jboss.util.naming.Util.lookup(Util.java:222)
| at org.jboss.resource.adapter.jms.inflow.dlq.AbstractDLQHandler.setupDLQDestination(AbstractDLQHandler.java:106)
| at org.jboss.resource.adapter.jms.inflow.dlq.AbstractDLQHandler.setup(AbstractDLQHandler.java:82)
| at org.jboss.resource.adapter.jms.inflow.dlq.JBossMQDLQHandler.setup(JBossMQDLQHandler.java:48)
| at org.jboss.resource.adapter.jms.inflow.JmsActivation.setupDLQ(JmsActivation.java:413)
| at org.jboss.resource.adapter.jms.inflow.JmsActivation.setup(JmsActivation.java:351)
| at org.jboss.resource.adapter.jms.inflow.JmsActivation.handleFailure(JmsActivation.java:292)
| at org.jboss.resource.adapter.jms.inflow.JmsActivation$SetupActivation.run(JmsActivation.java:733)
| at org.jboss.resource.work.WorkWrapper.execute(WorkWrapper.java:213)
| at org.jboss.util.threadpool.BasicTaskWrapper.run(BasicTaskWrapper.java:260)
| at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:651)
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:676)
| at java.lang.Thread.run(Thread.java:613)
| Caused by: javax.naming.ServiceUnavailableException: Failed to connect to server localhost/127.0.0.1:1099 [Root exception is java.net.ConnectException: Connection refused]
| at org.jnp.interfaces.NamingContext.getServer(NamingContext.java:301)
| ... 17 more
| Caused by: java.net.ConnectException: Connection refused
| at java.net.PlainSocketImpl.socketConnect(Native Method)
| at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:333)
| at java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:195)
| at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:182)
| at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:432)
| at java.net.Socket.connect(Socket.java:520)
| at org.jnp.interfaces.TimedSocketFactory.createSocket(TimedSocketFactory.java:97)
| at org.jnp.interfaces.TimedSocketFactory.createSocket(TimedSocketFactory.java:82)
| at org.jnp.interfaces.NamingContext.getServer(NamingContext.java:297)
| ... 17 more
| 14:12:53,540 ERROR [JmsActivation] Unable to reconnect org.jboss.resource.adapter.jms.inflow.JmsActivationSpec@74b6e6(ra=org.jboss.resource.adapter.jms.JmsResourceAdapter(a)2a032a destination=queue/DeliverMPOExternalMessageQueue destinationType=javax.jms.Queue tx=true durable=false reconnect=10 provider=java:/DefaultJMSProvider user=bssub pass=<not shown> maxMessages=1 minSession=1 maxSession=15 keepAlive=60000 useDLQ=true DLQHandler=org.jboss.resource.adapter.jms.inflow.dlq.GenericDLQHandler DLQJndiName=queue/DLQ DLQUser=null DLQMaxResent=5)
| javax.naming.CommunicationException: Could not obtain connection to any of these urls: localhost:1099 and discovery failed with error: javax.naming.CommunicationException: Receive timed out [Root exception is java.net.SocketTimeoutException: Receive timed out] [Root exception is javax.naming.CommunicationException: Failed to connect to server localhost/127.0.0.1:1099 [Root exception is javax.naming.ServiceUnavailableException: Failed to connect to server localhost/127.0.0.1:1099 [Root exception is java.net.ConnectException: Connection refused]]]
| at org.jnp.interfaces.NamingContext.checkRef(NamingContext.java:1725)
| at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:689)
| at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:682)
| at javax.naming.InitialContext.lookup(InitialContext.java:351)
| at org.jboss.util.naming.Util.lookup(Util.java:222)
| at org.jboss.resource.adapter.jms.inflow.dlq.AbstractDLQHandler.setupDLQDestination(AbstractDLQHandler.java:106)
| at org.jboss.resource.adapter.jms.inflow.dlq.AbstractDLQHandler.setup(AbstractDLQHandler.java:82)
| at org.jboss.resource.adapter.jms.inflow.dlq.JBossMQDLQHandler.setup(JBossMQDLQHandler.java:48)
| at org.jboss.resource.adapter.jms.inflow.JmsActivation.setupDLQ(JmsActivation.java:413)
| at org.jboss.resource.adapter.jms.inflow.JmsActivation.setup(JmsActivation.java:351)
| at org.jboss.resource.adapter.jms.inflow.JmsActivation.handleFailure(JmsActivation.java:292)
| at org.jboss.resource.adapter.jms.inflow.JmsActivation$SetupActivation.run(JmsActivation.java:733)
| at org.jboss.resource.work.WorkWrapper.execute(WorkWrapper.java:213)
| at org.jboss.util.threadpool.BasicTaskWrapper.run(BasicTaskWrapper.java:260)
| at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:651)
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:676)
| at java.lang.Thread.run(Thread.java:613)
| Caused by: javax.naming.CommunicationException: Failed to connect to server localhost/127.0.0.1:1099 [Root exception is javax.naming.ServiceUnavailableException: Failed to connect to server localhost/127.0.0.1:1099 [Root exception is java.net.ConnectException: Connection refused]]
| at org.jnp.interfaces.NamingContext.getServer(NamingContext.java:331)
| at org.jnp.interfaces.NamingContext.checkRef(NamingContext.java:1696)
| ... 16 more
| Caused by: javax.naming.ServiceUnavailableException: Failed to connect to server localhost/127.0.0.1:1099 [Root exception is java.net.ConnectException: Connection refused]
| at org.jnp.interfaces.NamingContext.getServer(NamingContext.java:301)
| ... 17 more
| Caused by: java.net.ConnectException: Connection refused
| at java.net.PlainSocketImpl.socketConnect(Native Method)
| at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:333)
| at java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:195)
| at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:182)
| at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:432)
| at java.net.Socket.connect(Socket.java:520)
| at org.jnp.interfaces.TimedSocketFactory.createSocket(TimedSocketFactory.java:97)
| at org.jnp.interfaces.TimedSocketFactory.createSocket(TimedSocketFactory.java:82)
| at org.jnp.interfaces.NamingContext.getServer(NamingContext.java:297)
| ... 17 more
|
|
|
The bean is obviously looking to connect over localhost and failing. How do i get around this
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4251627#4251627
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4251627
16 years, 8 months
[EJB 3.0 Users] - MDBs and -b option.
by k.k.ramachandran
Hi,
I'm having trouble deploying an mdb. It's a relatively simply EJB 3, MDB configured via annotations.
Here is the config:
| @MessageDriven(activationConfig = {
| @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"),
| @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
| @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/DeliverMPOExternalMessageQueue"),
| // @ActivationConfigProperty(propertyName = "providerAdapterJNDI", propertyValue = "java:/RemoteJMSProvider"),
| @ActivationConfigProperty(propertyName = "user", propertyValue = "user"),
| @ActivationConfigProperty(propertyName = "password", propertyValue = "password")
| })
|
This works fine when i simply start a server using ./run.sh. However when i bind the server to my ip address: ./run.sh -b 10.0.0.191 . I get the following errors:
| 14:12:48,538 DEBUG [NamingContext] Failed to connect to localhost:1099
| javax.naming.CommunicationException: Failed to connect to server localhost/127.0.0.1:1099 [Root exception is javax.naming.ServiceUnavailableException: Failed to connect to server localhost/127.0.0.1:1099 [Root exception is java.net.ConnectException: Connection refused]]
| at org.jnp.interfaces.NamingContext.getServer(NamingContext.java:331)
| at org.jnp.interfaces.NamingContext.checkRef(NamingContext.java:1696)
| at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:689)
| at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:682)
| at javax.naming.InitialContext.lookup(InitialContext.java:351)
| at org.jboss.util.naming.Util.lookup(Util.java:222)
| at org.jboss.resource.adapter.jms.inflow.dlq.AbstractDLQHandler.setupDLQDestination(AbstractDLQHandler.java:106)
| at org.jboss.resource.adapter.jms.inflow.dlq.AbstractDLQHandler.setup(AbstractDLQHandler.java:82)
| at org.jboss.resource.adapter.jms.inflow.dlq.JBossMQDLQHandler.setup(JBossMQDLQHandler.java:48)
| at org.jboss.resource.adapter.jms.inflow.JmsActivation.setupDLQ(JmsActivation.java:413)
| at org.jboss.resource.adapter.jms.inflow.JmsActivation.setup(JmsActivation.java:351)
| at org.jboss.resource.adapter.jms.inflow.JmsActivation.handleFailure(JmsActivation.java:292)
| at org.jboss.resource.adapter.jms.inflow.JmsActivation$SetupActivation.run(JmsActivation.java:733)
| at org.jboss.resource.work.WorkWrapper.execute(WorkWrapper.java:213)
| at org.jboss.util.threadpool.BasicTaskWrapper.run(BasicTaskWrapper.java:260)
| at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:651)
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:676)
| at java.lang.Thread.run(Thread.java:613)
| Caused by: javax.naming.ServiceUnavailableException: Failed to connect to server localhost/127.0.0.1:1099 [Root exception is java.net.ConnectException: Connection refused]
| at org.jnp.interfaces.NamingContext.getServer(NamingContext.java:301)
| ... 17 more
| Caused by: java.net.ConnectException: Connection refused
| at java.net.PlainSocketImpl.socketConnect(Native Method)
| at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:333)
| at java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:195)
| at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:182)
| at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:432)
| at java.net.Socket.connect(Socket.java:520)
| at org.jnp.interfaces.TimedSocketFactory.createSocket(TimedSocketFactory.java:97)
| at org.jnp.interfaces.TimedSocketFactory.createSocket(TimedSocketFactory.java:82)
| at org.jnp.interfaces.NamingContext.getServer(NamingContext.java:297)
| ... 17 more
| 14:12:53,540 ERROR [JmsActivation] Unable to reconnect org.jboss.resource.adapter.jms.inflow.JmsActivationSpec@74b6e6(ra=org.jboss.resource.adapter.jms.JmsResourceAdapter(a)2a032a destination=queue/DeliverMPOExternalMessageQueue destinationType=javax.jms.Queue tx=true durable=false reconnect=10 provider=java:/DefaultJMSProvider user=bssub pass=<not shown> maxMessages=1 minSession=1 maxSession=15 keepAlive=60000 useDLQ=true DLQHandler=org.jboss.resource.adapter.jms.inflow.dlq.GenericDLQHandler DLQJndiName=queue/DLQ DLQUser=null DLQMaxResent=5)
| javax.naming.CommunicationException: Could not obtain connection to any of these urls: localhost:1099 and discovery failed with error: javax.naming.CommunicationException: Receive timed out [Root exception is java.net.SocketTimeoutException: Receive timed out] [Root exception is javax.naming.CommunicationException: Failed to connect to server localhost/127.0.0.1:1099 [Root exception is javax.naming.ServiceUnavailableException: Failed to connect to server localhost/127.0.0.1:1099 [Root exception is java.net.ConnectException: Connection refused]]]
| at org.jnp.interfaces.NamingContext.checkRef(NamingContext.java:1725)
| at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:689)
| at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:682)
| at javax.naming.InitialContext.lookup(InitialContext.java:351)
| at org.jboss.util.naming.Util.lookup(Util.java:222)
| at org.jboss.resource.adapter.jms.inflow.dlq.AbstractDLQHandler.setupDLQDestination(AbstractDLQHandler.java:106)
| at org.jboss.resource.adapter.jms.inflow.dlq.AbstractDLQHandler.setup(AbstractDLQHandler.java:82)
| at org.jboss.resource.adapter.jms.inflow.dlq.JBossMQDLQHandler.setup(JBossMQDLQHandler.java:48)
| at org.jboss.resource.adapter.jms.inflow.JmsActivation.setupDLQ(JmsActivation.java:413)
| at org.jboss.resource.adapter.jms.inflow.JmsActivation.setup(JmsActivation.java:351)
| at org.jboss.resource.adapter.jms.inflow.JmsActivation.handleFailure(JmsActivation.java:292)
| at org.jboss.resource.adapter.jms.inflow.JmsActivation$SetupActivation.run(JmsActivation.java:733)
| at org.jboss.resource.work.WorkWrapper.execute(WorkWrapper.java:213)
| at org.jboss.util.threadpool.BasicTaskWrapper.run(BasicTaskWrapper.java:260)
| at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:651)
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:676)
| at java.lang.Thread.run(Thread.java:613)
| Caused by: javax.naming.CommunicationException: Failed to connect to server localhost/127.0.0.1:1099 [Root exception is javax.naming.ServiceUnavailableException: Failed to connect to server localhost/127.0.0.1:1099 [Root exception is java.net.ConnectException: Connection refused]]
| at org.jnp.interfaces.NamingContext.getServer(NamingContext.java:331)
| at org.jnp.interfaces.NamingContext.checkRef(NamingContext.java:1696)
| ... 16 more
| Caused by: javax.naming.ServiceUnavailableException: Failed to connect to server localhost/127.0.0.1:1099 [Root exception is java.net.ConnectException: Connection refused]
| at org.jnp.interfaces.NamingContext.getServer(NamingContext.java:301)
| ... 17 more
| Caused by: java.net.ConnectException: Connection refused
| at java.net.PlainSocketImpl.socketConnect(Native Method)
| at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:333)
| at java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:195)
| at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:182)
| at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:432)
| at java.net.Socket.connect(Socket.java:520)
| at org.jnp.interfaces.TimedSocketFactory.createSocket(TimedSocketFactory.java:97)
| at org.jnp.interfaces.TimedSocketFactory.createSocket(TimedSocketFactory.java:82)
| at org.jnp.interfaces.NamingContext.getServer(NamingContext.java:297)
| ... 17 more
|
Any hints?
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4251625#4251625
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4251625
16 years, 8 months
[jBPM Users] - Re: How to control process transition in JBPM 4.0?
by jbpmjboss11
Thanks for the response.
To explain my problem in more detail ... What I am planning to do is ...
1. I have a web application say 3-4 screens. I have created JBPM flow as one page backend code as one process state.
2. I don't want to tie up my UI with JBPM. When user clicks on first page, backend java component will be called through JBPM.
3. Like, first screen "submit" button will initiate the process, and calls the class mentioned in first java task with proper input and receive response.
4. Now I send this output to the user screen (my first state/task is complete).
5. Here I want transition from first state/task to second state/task to be on hold till user moves to second screen.
Do you think this is possible? So far I have not seen anything in JBPM API which can hold process from transitioning once state/task is over.
Thanks
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4251624#4251624
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4251624
16 years, 8 months