how AMQP connection can be active upto lifetime of application

2018-06-30 Thread Abhishek Kumar
epAlive=true&amqp.traceFrames=true&jms.prefetchPolicy.all=1000&jms.validatePropertyNames=false&jms.forceSyncSend=true <http://servicebus.windows.net?amqp.idleTimeout=-1&transport.tcpKeepAlive=true&amqp.traceFrames=true&jms.prefetchPolicy.all=1000&jms.validatePropertyNames=false&jms.forceSyncSend=true>”* Regards, Abhishek Kumar

how to set ServiceBus Message properties like MessageID, ContentType, PartitionKey ?

2018-06-20 Thread Abhishek Kumar
age.setObjectProperty("ContentType", "application/json"); Destination replyTo = session.createQueue("connector-test"); textMessage.setJMSReplyTo(replyTo ); textMessage.setJMSCorrelationID("akdhadsajksd-123-1232131"); Regards, Abhishek Kumar -

Message going in topic with the use of "session.createQueue(name)"

2018-06-13 Thread Abhishek Kumar
uld go to Topic, its going to Queue and vice versa. As it seems that the library is checking only for resource names and does not care whether its a Topic or a Queue; As it seems the implementation is mis-leading. Is this an expected behavior from the library? Regards, Abhishek Kumar

producer exception handling for 10m idle TimeOut -> "qpid-jms-client - 0.32.0"

2018-06-06 Thread Abhishek Kumar
essage.getJMSMessageID() +", Exception Message :: "+ exception.getMessage()); exception.printStackTrace(); } catch (JMSException e) { e.printStackTrace(); } } } } Regards, Abhishek Kumar

Re: MessageListener stop listening message and producer stop sending message, -> "qpid-jms-client - 0.32.0"

2018-05-29 Thread Abhishek Kumar
tion. I think, I have to go ahead with Rob suggestion. Regards, abhishek kumar -- Sent from: http://qpid.2158936.n2.nabble.com/Apache-Qpid-users-f2158936.html - To unsubscribe, e-mail: users-unsubscr...@qpid.apache.org

MessageListener stop listening message and producer stop sending message, -> "qpid-jms-client - 0.32.0"

2018-05-24 Thread Abhishek Kumar
ssue. This is very bad alternative. Could you please suggest your opinion to resolve this issue. Regards, Abhishek Kumar

receive() operation increasing message delivery count for all message instead of 1 message

2018-05-24 Thread Abhishek Kumar
sumer(queue); connection.start(); System.out.println("*** Connection Start "); Message message = messageConsumer.receive(1000); long jmsTimestamp = message.getJMSTimestamp(); System.out.println("jmsTimestamp :: " + jmsTimestamp); message.acknowledge(); System.out.println(" END ***"); connection.close(); context.close(); } } Regards, Abhishek Kumar

Qpid - How can create JMS Message without using session

2018-05-10 Thread Abhishek Kumar
use active-mq library which i want avoid due adding more dependency. Could you please suggest any better way to create JMS Message without JMS session? Regards, Abhishek Kumar

qpid-jms-client --> 0.31.0, Azure Service Bus -> One Queue multiple consumer

2018-05-01 Thread Abhishek Kumar
messages (like 100200 or 100300). Could you please suggest your opinion on below questions 1. Can i have multiple consumer on one queue? Broker - Azure ServiceBus, 2. If yes, can you please suggest best way to create multiple consumer on single qeuue. Regards, Abhishek Kumar

qpid-jms-client --> 0.31.0, Azure Service Bus - Cannot allocate more handles to the current session or connection. The maximum number of handles allowed is 4999.

2018-04-23 Thread Abhishek Kumar
geProducer(producer); this.setDestination(destination); this.setConnection(connection); *Sender - Parallel 16 threads are running to send* * producer.send(jmsMessage);* Regards, Abhishek Kumar

Need Help to send Batch message with Qpid JmS in Java

2018-03-23 Thread Abhishek Kumar
? Regards, Abhishek Kumar -- Sent from: http://qpid.2158936.n2.nabble.com/Apache-Qpid-users-f2158936.html - To unsubscribe, e-mail: users-unsubscr...@qpid.apache.org For additional commands, e-mail: users-h...@qpid.apache.org

Qpid Proton J - 0.26.0, Need help to Create SASL connection for connecting Azure Service Bus

2018-03-22 Thread Abhishek Kumar
more Regards, Abhishek Kumar package org.apache.qpid.proton.example.reactor; import java.io.IOException; import java.nio.BufferOverflowException; import java.util.logging.LogManager; import org.apache.qpid.proton.Proton; import org.apache.qpid.proton.amqp.messaging.A