problem about forwarding bridge from VM to remote host

2013-11-08 Thread smith_jor
There is an embedded broker inside application, application sends messages to this vm ,and vm forwards messages to remote broker A. there is a consumer receiving messages on remote broker A using asyn mode. the configure uri like this - "vm:(broker:(network:static:(tcp://remotehostA:61616))?persis

question about static network connector?

2013-11-07 Thread smith_jor
Now, I have a JDBC master/slave cluster: tcp://remote1:61616, tcp://remote2:61616, tcp:/remote3:61616 I start a VM , application write message to VM, then VM forward messages to this master/slave cluster. core code is below: ActiveMQConnectionFactory factory = new ActiveMQConne

Can I improve throughput by adding connection number to Activemq provider?

2013-08-19 Thread smith_jor
suppose that application A send message to ActiveMQ B which has a queue named "testqueue". Can this method improve thoughtput ? application A create more than one connections to provider, then A send messages to the same queue (such "testqueue") using all these connections. Can this method works

Re: when Consumer consume a message using method receive(), why the mesage does not dequeue from activeMQ?

2013-08-05 Thread smith_jor
I used "session = connection.createSession(false,2);" to create a session. when I changto "session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);" Consumer can successfully dequeue message from MQ. It works!!! but which scenario "create.Session(false, 2)" can use? when and wh

when Consumer consume a message using method receive(), why the mesage does not dequeue from activeMQ?

2013-08-05 Thread smith_jor
I'm a beginner with activemq, now I try to use method receive() in class MessageConsumer. yes , it can get messages successfully. but when I browse this queue, these messages still in it? How can I receive a message ,at same time delete this message from queue ? since when I restart consumer , I