Advertisement
Guest User

Untitled

a guest
Oct 27th, 2016
87
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 7.06 KB | None | 0 0
  1. 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
  2. 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]
  3. at org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToException(AmqpSupport.java:150)
  4. at org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToException(AmqpSupport.java:105)
  5. at org.apache.qpid.jms.provider.amqp.AmqpAbstractResource.remotelyClosed(AmqpAbstractResource.java:147)
  6. at org.apache.qpid.jms.provider.amqp.AmqpAbstractResource.processRemoteClose(AmqpAbstractResource.java:251)
  7. at org.apache.qpid.jms.provider.amqp.AmqpProvider.processUpdates(AmqpProvider.java:771)
  8. at org.apache.qpid.jms.provider.amqp.AmqpProvider.access$1900(AmqpProvider.java:90)
  9. at org.apache.qpid.jms.provider.amqp.AmqpProvider$17.run(AmqpProvider.java:699)
  10. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
  11. at java.util.concurrent.FutureTask.run(FutureTask.java:262)
  12. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178)
  13. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292)
  14. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
  15. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
  16. at java.lang.Thread.run(Thread.java:745)
  17.  
  18. # servicebus.properties - sample JNDI configuration
  19.  
  20. # Register a ConnectionFactory in JNDI using the form:
  21. # connectionfactory.[jndi_name] = [ConnectionURL]
  22.  
  23. connectionfactory.myFactoryLookup = amqps://example-open-bus.servicebus.windows.net?jms.username=somePolicy&jms.password=aM2k3PaZY5jdIkmGKm7G%2FcH%2BUFQaFAgHIYc3dSsuiLI%3D&transport.connectTimeout=6000
  24.  
  25. # Register some queues in JNDI using the form
  26. # queue.[jndi_name] = [physical_name]
  27. # topic.[jndi_name] = [physical_name]
  28.  
  29. queue.myQueueLookup = queue1
  30.  
  31. package com.unit4.AzureTest;
  32.  
  33. import javax.jms.*;
  34. import javax.naming.Context;
  35. import javax.naming.InitialContext;
  36. import java.io.BufferedReader;
  37. import java.io.InputStreamReader;
  38. import java.util.Hashtable;
  39. import java.util.Random;
  40.  
  41. public class SimpleSenderReceiver implements MessageListener {
  42.  
  43. private static boolean runReceiver = false;
  44. private Connection connection;
  45. private Session sendSession;
  46. private Session receiveSession;
  47. private MessageProducer sender;
  48. private MessageConsumer receiver;
  49. private static Random randomGenerator = new Random();
  50.  
  51. public SimpleSenderReceiver() throws Exception {
  52. // Configure JNDI environment
  53. Hashtable<String, String> env = new Hashtable<String, String>();
  54. env.put(Context.INITIAL_CONTEXT_FACTORY,
  55. "org.apache.qpid.jms.jndi.JmsInitialContextFactory");
  56. env.put(Context.PROVIDER_URL, "C://PATH//servicebus.properties");
  57. Context context = new InitialContext(env);
  58.  
  59. // Look up ConnectionFactory and Queue
  60. ConnectionFactory cf = (ConnectionFactory) context.lookup("myFactoryLookup");
  61. System.out.println("lookup: " + context.lookup("myFactoryLookup"));
  62. System.out.println("cf:"+cf);
  63. Destination queue = (Destination) context.lookup("myQueueLookup");
  64.  
  65. System.out.println("queue:");
  66.  
  67. // Create Connection
  68. connection = cf.createConnection();
  69. System.out.println("connection :"+connection);
  70.  
  71. // // Create sender-side Session and MessageProducer
  72. sendSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  73. System.out.println("Session open.");
  74.  
  75. sender = sendSession.createProducer(queue);
  76. System.out.println(sender.getDestination());
  77. System.out.println("sender:"+sender);
  78.  
  79. if (runReceiver) {
  80. // Create receiver-side Session, MessageConsumer,and MessageListener
  81. receiveSession = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
  82. receiver = receiveSession.createConsumer(queue);
  83. receiver.setMessageListener(this);
  84. connection.start();
  85. }
  86. }
  87.  
  88. public static void main(String[] args) {
  89. try {
  90.  
  91. if ((args.length > 0) && args[0].equalsIgnoreCase("sendonly")) {
  92. runReceiver = false;
  93. }
  94.  
  95. SimpleSenderReceiver simpleSenderReceiver = new SimpleSenderReceiver();
  96. System.out.println("Press [enter] to send a message. Type 'exit' + [enter] to quit.");
  97. BufferedReader commandLine = new java.io.BufferedReader(new InputStreamReader(System.in));
  98.  
  99. while (true) {
  100. String s = commandLine.readLine();
  101. if (s.equalsIgnoreCase("exit")) {
  102. simpleSenderReceiver.close();
  103. System.exit(0);
  104. } else {
  105. simpleSenderReceiver.sendMessage();
  106. }
  107. }
  108. } catch (Exception e) {
  109. e.printStackTrace();
  110. }
  111. }
  112.  
  113. private void sendMessage() throws JMSException {
  114. TextMessage message = sendSession.createTextMessage();
  115. message.setText("Hello from SIS Test AMQP message from Java JMSaaa");
  116. long randomMessageID = randomGenerator.nextLong() >>>1;
  117. message.setStringProperty("TenantId", "klant");
  118. message.setStringProperty("EventType", "bericht");
  119. message.setStringProperty("EventTypeVersion", "1.0");
  120. message.setStringProperty("MessageType", "DocumentMessage");
  121. message.setStringProperty("OperationType", "Create");
  122. message.setStringProperty("SourceSystem", "sis_sender");
  123. message.setStringProperty("EnterpriseKey", "sis_sender-klant-bericht");
  124. message.setJMSMessageID("ID:" + randomMessageID);
  125. sender.send(message);
  126. System.out.println("Sent message with JMSMessageID = " + message.getJMSMessageID());
  127. System.out.println("Sent message with Text = " + message.getText());
  128. }
  129.  
  130. public void close() throws JMSException {
  131. connection.close();
  132. }
  133.  
  134. public void onMessage(Message message) {
  135. try {
  136. System.out.println("Received message with JMSMessageID = " + message.getJMSMessageID());
  137. TextMessage txtmessage = (TextMessage) message;
  138. System.out.println("Received message with Text = " + txtmessage.getText());
  139. message.acknowledge();
  140. } catch (Exception e) {
  141. e.printStackTrace();
  142. }
  143. }
  144. }
  145.  
  146. <dependencies>
  147. <dependency>
  148. <groupId>org.apache.qpid</groupId>
  149. <artifactId>qpid-jms-client</artifactId>
  150. <version>0.11.1</version>
  151. </dependency>
  152. <!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-simple -->
  153. <dependency>
  154. <groupId>org.slf4j</groupId>
  155. <artifactId>slf4j-simple</artifactId>
  156. <version>1.6.2</version>
  157. </dependency>
  158. </dependencies>
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement