Check the broker using jconsole that the queue names match and that you
aren't creating 2 different queues.
I had a similar problem using the Perl Stomp client.
I think Stomp Topics and Queues get created with a name like
TOPIC/<topicName> and QUEUE/<queueName>
I may be rusty on the format etc.
Gaurav
[EMAIL PROTECTED] wrote:
I have attached the source code.
My environment is:
- Windows XP Home SP2
- JDK1.5.0_08-b03
- for C++ MS VisualStudio 2005
Thanks,
Grzegorz
---- Timothy Bish <[EMAIL PROTECTED]> schrieb:
Without seeing source code its hard to say. One thing to check is to ensure
that you are letting the C++ consumer start and connect before the Java
producer sends its messages.
-----Original Message-----
From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED]
Sent: Saturday, March 03, 2007 8:59 AM
To: users@activemq.apache.org
Cc: Timothy Bish
Subject: RE: Java Producer and C++ Consumer
Importance: High
Hi,
my C++ client is connected to tcp://localhost:61613.
Of course I have tried the Java Producer with the URL
tcp://localhost:61616 and the messages were created.
My problem is that the C++ Consumer did not received anything (but is
successfully connected to the queue TEST.FOO).
If I start a Java Consumer all is fine.
Grzegorz
---- Timothy Bish <[EMAIL PROTECTED]> schrieb:
The Java Producer should probably be using tcp://localhost:61616 as its
url,
as that is the default for the openwire transport connector in the
broker.
The C++ client would connect to tcp://localhost:61613 assuming that you
have
the default stomp settings the same in your broker's configuration.
Once you do that you should be all set.
The openwire support in the C++ client is close, I'm working on some
issues
with tight marshalling now, but loose marshalling seems to be working
just
fine. We are working on new integration tests and unit tests to
validate
all the new functionality. Its only a matter of time now. I've got a
busy
week next week so it might get delayed a bit until I get a chance to
work on
it some more.
-----Original Message-----
From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED]
Sent: Saturday, March 03, 2007 6:53 AM
To: users@activemq.apache.org
Subject: Java Producer and C++ Consumer
Importance: High
I have ActiveMQ 4.1.0 and ActiveMQ-CPP 1.1 installed.
The language specific examples (Java producer/Java consumers
respectively
C++ producer/C++ consumers) work fine.
Is it now possible with the Stomp protocol to have ordinary JMS
producers
written in Java and queue consumers written in C++? I tried it, but
without success. I got always following exception trying to start Java
producer using this URL tcp://localhost:61613
Caught: javax.jms.JMSException: Wire format negociation timeout: peer
did
not send his wire format.
Will be possible to have the interconnection (Java and C++) with the
OpenWire protocol?
When do you expect to release the OpenWire C++ implementation?
Thanks,
Grzegorz
------------------------------------------------------------------------
#include <activemq/core/ActiveMQConsumer.h>
#include <activemq/core/ActiveMQConnectionFactory.h>
#include <iostream>
#include <memory>
#include <string>
using namespace activemq;
using namespace activemq::core;
using namespace cms;
using namespace std;
int main(int argc, char** argv)
{
string uri = "tcp://127.0.0.1:61613";
string queueName = "TEST.FOO";
if (argc > 1) {
uri = argv[1];
if (argc > 2) {
queueName = argv[2];
}
}
auto_ptr<ConnectionFactory> factory(new ActiveMQConnectionFactory(uri));
try {
cout << "create connection" << endl;
auto_ptr<Connection> conn(factory->createConnection());
cout << "create session" << endl;
auto_ptr<Session>
sess(conn->createSession(Session::AUTO_ACKNOWLEDGE));
cout << "get queue" << endl;
auto_ptr<Destination> queue(sess->createQueue(queueName));
cout << "create consumer" << endl;
auto_ptr<MessageConsumer>
consumer(sess->createConsumer(queue.get()));
while (true) {
cout << "wait for message" << endl;
auto_ptr<Message> msg(consumer->receive(10000));
if (msg.get()) {
cout << "got message" << endl;
}
else {
cout << "Timeout" << endl;
}
}
} catch (...) {
cerr << "Exception catched!" << endl;
return -1;
}
return 0;
}
------------------------------------------------------------------------
import java.util.Arrays;
import java.util.Date;
import javax.jms.Connection;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
public class Producer {
private Destination destination;
private int messageCount = 10;
private long sleepTime = 0L;
private boolean verbose = true;
private int messageSize = 255;
private long timeToLive = 0L;
private String user = null;
private String password = null;
private static String url = "tcp://127.0.0.1:61616";
private String subject = "TEST.FOO";
private boolean topic = false;
private boolean transacted = false;
private boolean persistent = false;
public static void main(String[] args) {
if (args.length > 0) {
url = args[0];
}
Producer producerTool = new Producer();
producerTool.run();
}
public void run() {
Connection connection=null;
try {
System.out.println("Connecting to URL: " + url);
System.out.println("Publishing a Message with size " + messageSize+ " to " + (topic ?
"topic" : "queue") + ": " + subject);
System.out.println("Using " + (persistent ? "persistent" :
"non-persistent") + " messages");
System.out.println("Sleeping between publish " + sleepTime +
" ms");
if (timeToLive != 0) {
System.out.println("Messages time to live " + timeToLive
+ " ms");
}
// Create the connection.
ActiveMQConnectionFactory connectionFactory = new
ActiveMQConnectionFactory(url);
connection = connectionFactory.createConnection();
// Create the session
Session session = connection.createSession(transacted,
Session.AUTO_ACKNOWLEDGE);
if (topic) {
destination = session.createTopic(subject);
} else {
destination = session.createQueue(subject);
}
// Create the producer.
MessageProducer producer =
session.createProducer(destination);
if (persistent) {
producer.setDeliveryMode(DeliveryMode.PERSISTENT);
} else {
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
}
if (timeToLive != 0)
producer.setTimeToLive(timeToLive);
connection.start();
// Start sending messages
sendLoop(session, producer);
System.out.println("Done.");
} catch (Exception e) {
System.out.println("Caught: " + e);
e.printStackTrace();
} finally {
try {
connection.close();
} catch (Throwable ignore) {
}
}
}
protected void sendLoop(Session session, MessageProducer producer)
throws Exception {
for (int i = 0; i < messageCount || messageCount == 0; i++) {
TextMessage message = session
.createTextMessage(createMessageText(i));
if (verbose) {
String msg = message.getText();
if (msg.length() > 50) {
msg = msg.substring(0, 50) + "...";
}
System.out.println("Sending message: " + msg);
}
producer.send(message);
if (transacted) {
session.commit();
}
Thread.sleep(sleepTime);
}
}
private String createMessageText(int index) {
StringBuffer buffer = new StringBuffer(messageSize);
buffer.append("Message: " + index + " sent at: " + new Date());
if (buffer.length() > messageSize) {
return buffer.substring(0, messageSize);
}
for (int i = buffer.length(); i < messageSize; i++) {
buffer.append(' ');
}
return buffer.toString();
}
public void setPersistent(boolean durable) {
this.persistent = durable;
}
public void setMessageCount(int messageCount) {
this.messageCount = messageCount;
}
public void setMessageSize(int messageSize) {
this.messageSize = messageSize;
}
public void setPassword(String pwd) {
this.password = pwd;
}
public void setSleepTime(long sleepTime) {
this.sleepTime = sleepTime;
}
public void setSubject(String subject) {
this.subject = subject;
}
public void setTimeToLive(long timeToLive) {
this.timeToLive = timeToLive;
}
public void setTopic(boolean topic) {
this.topic = topic;
}
public void setQueue(boolean queue) {
this.topic = !queue;
}
public void setTransacted(boolean transacted) {
this.transacted = transacted;
}
public void setUrl(String url) {
this.url = url;
}
public void setUser(String user) {
this.user = user;
}
public void setVerbose(boolean verbose) {
this.verbose = verbose;
}
}
