Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 731 [AmqpProvider:(1):[amqps://example-bus.servicebus.windows.net?transport.connectTimeout=60000]] INFO org.apache.qpid.jms.sasl.SaslMechanismFinder - Best match for SASL auth was: SASL-PLAIN
- javax.jms.JMSException: Idle timeout value specified in connection OPEN ('30000 ms') is not supported. Minimum idle timeout is '60000' ms. TrackingId:238849ced1em4cd3a093261372f4fc1e_G21, SystemTracker:gateway6, Timestamp:10/27/2016 8:16:23 AM [condition = amqp:internal-error]
- at org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToException(AmqpSupport.java:150)
- at org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToException(AmqpSupport.java:105)
- at org.apache.qpid.jms.provider.amqp.AmqpAbstractResource.remotelyClosed(AmqpAbstractResource.java:147)
- at org.apache.qpid.jms.provider.amqp.AmqpAbstractResource.processRemoteClose(AmqpAbstractResource.java:251)
- at org.apache.qpid.jms.provider.amqp.AmqpProvider.processUpdates(AmqpProvider.java:771)
- at org.apache.qpid.jms.provider.amqp.AmqpProvider.access$1900(AmqpProvider.java:90)
- at org.apache.qpid.jms.provider.amqp.AmqpProvider$17.run(AmqpProvider.java:699)
- at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
- at java.util.concurrent.FutureTask.run(FutureTask.java:262)
- at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178)
- at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:745)
- # servicebus.properties - sample JNDI configuration
- # Register a ConnectionFactory in JNDI using the form:
- # connectionfactory.[jndi_name] = [ConnectionURL]
- connectionfactory.myFactoryLookup = amqps://example-open-bus.servicebus.windows.net?jms.username=somePolicy&jms.password=aM2k3PaZY5jdIkmGKm7G%2FcH%2BUFQaFAgHIYc3dSsuiLI%3D&transport.connectTimeout=6000
- # Register some queues in JNDI using the form
- # queue.[jndi_name] = [physical_name]
- # topic.[jndi_name] = [physical_name]
- queue.myQueueLookup = queue1
- package com.unit4.AzureTest;
- import javax.jms.*;
- import javax.naming.Context;
- import javax.naming.InitialContext;
- import java.io.BufferedReader;
- import java.io.InputStreamReader;
- import java.util.Hashtable;
- import java.util.Random;
- public class SimpleSenderReceiver implements MessageListener {
- private static boolean runReceiver = false;
- private Connection connection;
- private Session sendSession;
- private Session receiveSession;
- private MessageProducer sender;
- private MessageConsumer receiver;
- private static Random randomGenerator = new Random();
- public SimpleSenderReceiver() throws Exception {
- // Configure JNDI environment
- Hashtable<String, String> env = new Hashtable<String, String>();
- env.put(Context.INITIAL_CONTEXT_FACTORY,
- "org.apache.qpid.jms.jndi.JmsInitialContextFactory");
- env.put(Context.PROVIDER_URL, "C://PATH//servicebus.properties");
- Context context = new InitialContext(env);
- // Look up ConnectionFactory and Queue
- ConnectionFactory cf = (ConnectionFactory) context.lookup("myFactoryLookup");
- System.out.println("lookup: " + context.lookup("myFactoryLookup"));
- System.out.println("cf:"+cf);
- Destination queue = (Destination) context.lookup("myQueueLookup");
- System.out.println("queue:");
- // Create Connection
- connection = cf.createConnection();
- System.out.println("connection :"+connection);
- // // Create sender-side Session and MessageProducer
- sendSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
- System.out.println("Session open.");
- sender = sendSession.createProducer(queue);
- System.out.println(sender.getDestination());
- System.out.println("sender:"+sender);
- if (runReceiver) {
- // Create receiver-side Session, MessageConsumer,and MessageListener
- receiveSession = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
- receiver = receiveSession.createConsumer(queue);
- receiver.setMessageListener(this);
- connection.start();
- }
- }
- public static void main(String[] args) {
- try {
- if ((args.length > 0) && args[0].equalsIgnoreCase("sendonly")) {
- runReceiver = false;
- }
- SimpleSenderReceiver simpleSenderReceiver = new SimpleSenderReceiver();
- System.out.println("Press [enter] to send a message. Type 'exit' + [enter] to quit.");
- BufferedReader commandLine = new java.io.BufferedReader(new InputStreamReader(System.in));
- while (true) {
- String s = commandLine.readLine();
- if (s.equalsIgnoreCase("exit")) {
- simpleSenderReceiver.close();
- System.exit(0);
- } else {
- simpleSenderReceiver.sendMessage();
- }
- }
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- private void sendMessage() throws JMSException {
- TextMessage message = sendSession.createTextMessage();
- message.setText("Hello from SIS Test AMQP message from Java JMSaaa");
- long randomMessageID = randomGenerator.nextLong() >>>1;
- message.setStringProperty("TenantId", "klant");
- message.setStringProperty("EventType", "bericht");
- message.setStringProperty("EventTypeVersion", "1.0");
- message.setStringProperty("MessageType", "DocumentMessage");
- message.setStringProperty("OperationType", "Create");
- message.setStringProperty("SourceSystem", "sis_sender");
- message.setStringProperty("EnterpriseKey", "sis_sender-klant-bericht");
- message.setJMSMessageID("ID:" + randomMessageID);
- sender.send(message);
- System.out.println("Sent message with JMSMessageID = " + message.getJMSMessageID());
- System.out.println("Sent message with Text = " + message.getText());
- }
- public void close() throws JMSException {
- connection.close();
- }
- public void onMessage(Message message) {
- try {
- System.out.println("Received message with JMSMessageID = " + message.getJMSMessageID());
- TextMessage txtmessage = (TextMessage) message;
- System.out.println("Received message with Text = " + txtmessage.getText());
- message.acknowledge();
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- }
- <dependencies>
- <dependency>
- <groupId>org.apache.qpid</groupId>
- <artifactId>qpid-jms-client</artifactId>
- <version>0.11.1</version>
- </dependency>
- <!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-simple -->
- <dependency>
- <groupId>org.slf4j</groupId>
- <artifactId>slf4j-simple</artifactId>
- <version>1.6.2</version>
- </dependency>
- </dependencies>
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement