** Reason for termination ==
** {function_clause,
[{rabbit_amqp1_0_link_util,'-outcomes/1-lc$^0/1-0-',
[{list,
[{symbol,<<"amqp:accepted:list">>},
{symbol,<<"amqp:rejected:list">>},
{symbol,<<"amqp:released:list">>},
{symbol,<<"amqp:modified:list">>}]}],
[{file,"src/rabbit_amqp1_0_link_util.erl"},{line,49}]},
{rabbit_amqp1_0_link_util,outcomes,1,
[{file,"src/rabbit_amqp1_0_link_util.erl"},{line,49}]},
{rabbit_amqp1_0_outgoing_link,attach,3,
[{file,"src/rabbit_amqp1_0_outgoing_link.erl"},{line,41}]},
{rabbit_amqp1_0_session_process,with_disposable_channel,2,
[{file,"src/rabbit_amqp1_0_session_process.erl"},{line,377}]},
{rabbit_amqp1_0_session_process,handle_control,2,
[{file,"src/rabbit_amqp1_0_session_process.erl"},{line,197}]},
{rabbit_amqp1_0_session_process,handle_cast,2,
[{file,"src/rabbit_amqp1_0_session_process.erl"},{line,134}]},
{gen_server2,handle_msg,2,[{file,"src/gen_server2.erl"},{line,1049}]},
{proc_lib,init_p_do_apply,3,[{file,"proc_lib.erl"},{line,240}]}]}
=ERROR REPORT==== 8-Jul-2016::17:09:27 ===
closing AMQP connection <0.29082.0> (127.0.0.1:55479 -> 127.0.0.1:5672):
{handshake_error,running,<0.29104.0>,
{{symbol,<<"amqp:internal-error">>},
"Session error: ~p~n~p~n",
[function_clause,
[{rabbit_amqp1_0_link_util,'-outcomes/1-lc$^0/1-0-',
[{list,
[{symbol,<<"amqp:accepted:list">>},
{symbol,<<"amqp:rejected:list">>},
{symbol,<<"amqp:released:list">>},
{symbol,<<"amqp:modified:list">>}]}],
[{file,"src/rabbit_amqp1_0_link_util.erl"},{line,49}]},
{rabbit_amqp1_0_link_util,outcomes,1,
[{file,"src/rabbit_amqp1_0_link_util.erl"},{line,49}]},
{rabbit_amqp1_0_outgoing_link,attach,3,
[{file,"src/rabbit_amqp1_0_outgoing_link.erl"},{line,41}]},
{rabbit_amqp1_0_session_process,with_disposable_channel,2,
[{file,"src/rabbit_amqp1_0_session_process.erl"},{line,377}]},
{rabbit_amqp1_0_session_process,handle_control,2,
[{file,"src/rabbit_amqp1_0_session_process.erl"},{line,197}]},
{rabbit_amqp1_0_session_process,handle_cast,2,
[{file,"src/rabbit_amqp1_0_session_process.erl"},{line,134}]},
{gen_server2,handle_msg,2,[{file,"src/gen_server2.erl"},{line,1049}]},
{proc_lib,init_p_do_apply,3,[{file,"proc_lib.erl"},{line,240}]}]]}}
import org.apache.qpid.jms.JmsConnectionFactory;
import javax.jms.*;
import java.io.InputStream;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
/**
* Created by VISHAL on 11-07-2016.
*/
public class RabbitMQTest {
public static void main(String[] args) {
RabbitMQTest test = new RabbitMQTest();
test.runTest();
}
private void runTest() {
try (InputStream propertiesStream = getClass().getResourceAsStream("/application.properties")) {
JmsConnectionFactory connectionFactory = new JmsConnectionFactory("guest", "guest", "amqp://127.0.0.1:5672");
Connection connection = connectionFactory.createConnection();
Session producersession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = new Queue() {
@Override
public String getQueueName() throws JMSException {
return "testQueue2";
}
};
Session consumerSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageConsumer messageConsumer = consumerSession.createConsumer(queue);
final CountDownLatch latch = new CountDownLatch(1);
messageConsumer.setMessageListener(new MessageListener() {
public void onMessage(final Message message) {
try {
if (message instanceof TextMessage) {
System.out.println(((TextMessage) message).getText());
} else {
System.out.println("Received enexpected message type: " + message.getClass().getName());
}
latch.countDown();
} catch (JMSException e) {
System.out.println("Caught exception in onMessage(): " + e.getMessage());
}
}
});
connection.start();
MessageProducer messageProducer = producersession.createProducer(queue);
TextMessage message = producersession.createTextMessage("Hello world!");
messageProducer.send(message);
int delay = 5;
if (!latch.await(delay, TimeUnit.SECONDS)) {
System.out.println("Waited " + delay + "sec but no message recieved.");
}
connection.close();
} catch (
Exception exp
)
{
System.out.println("Caught exception: " + exp.getMessage());
exp.printStackTrace();
}
}
}
--
You received this message because you are subscribed to the Google Groups "rabbitmq-users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to rabbitmq-user...@googlegroups.com.
To post to this group, send email to rabbitm...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
=INFO REPORT==== 13-May-2017::10:49:54 ===
accepting AMQP connection <0.799.0> (127.0.0.1:51879 -> 127.0.0.1:5672)
=WARNING REPORT==== 13-May-2017::10:49:54 ===
Closing session for connection <0.799.0>:
=INFO REPORT==== 2-Aug-2017::13:24:16 === accepting AMQP connection <0.2055.0> (10.0.2.2:57459 -> 172.17.0.2:5672) =WARNING REPORT==== 2-Aug-2017::13:24:16 === Closing session for connection <0.2055.0>: {'v1_0.error',{symbol,<<"amqp:not-implemented">>}, {utf8,<<"Outcomes not supported: [{symbol,<<\"amqp:modified:list\">>}]">>}, undefined} =WARNING REPORT==== 2-Aug-2017::13:24:27 === closing AMQP connection <0.2055.0> (10.0.2.2:57459 -> 172.17.0.2:5672): client unexpectedly closed TCP connection
package com.myself.test;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.qpid.jms.JmsConnectionFactory;
public class AmqpJmsSenderApp {
public static void main(String[] args) throws Exception {
Connection connection = null;
ConnectionFactory connectionFactory = new JmsConnectionFactory("amqp://localhost:30000");
try {
// Step 1. Create an amqp qpid 1.0 connection
connection = connectionFactory.createConnection("admin", "pass");
// Step 2. Create a session
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
// Step 3. Create a sender
Queue queue = session.createQueue("/amq/queue/CRM.TEST.QUEUE");
MessageProducer sender = session.createProducer(queue);
// Step 4. send a few simple message
sender.send(session.createTextMessage("Hello world "));
connection.start();
// Step 5. create a moving receiver, this means the message will be
// removed from the queue
MessageConsumer consumer = session.createConsumer(queue);
// Step 7. receive the simple message
TextMessage m = (TextMessage) consumer.receive(5000);
System.out.println("message = " + m.getText());
} finally {
if (connection != null) {
// Step 9. close the connection
connection.close();
}
}
}
}
To unsubscribe from this group and stop receiving emails from it, send an email to rabbitmq-users+unsubscribe@googlegroups.com.
To post to this group, send email to rabbitmq-users@googlegroups.com.
To unsubscribe from this group and stop receiving emails from it, send an email to rabbitmq-users+unsubscribe@googlegroups.com.
To post to this group, send email to rabbitmq-users@googlegroups.com.