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
age.setObjectProperty("ContentType", "application/json");
Destination replyTo = session.createQueue("connector-test");
textMessage.setJMSReplyTo(replyTo );
textMessage.setJMSCorrelationID("akdhadsajksd-123-1232131");
Regards,
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
essage.getJMSMessageID() +", Exception Message :: "+
exception.getMessage());
exception.printStackTrace();
} catch (JMSException e) {
e.printStackTrace();
}
}
}
}
Regards,
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
ssue. This is very bad
alternative.
Could you please suggest your opinion to resolve this issue.
Regards,
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
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
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
geProducer(producer);
this.setDestination(destination);
this.setConnection(connection);
*Sender - Parallel 16 threads are running to send*
* producer.send(jmsMessage);*
Regards,
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
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
12 matches
Mail list logo