You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by jefetech <in...@jefetech.com> on 2006/09/05 20:52:16 UTC
Java sending message to listening ajax
I've got all my ajax send/receive working, however I need a java program to
be able to send/receive message from the ajax. Why does the ajax not
receive this? Do I need simulate a httppost instead of this?
ActiveMQConnectionFactory connectionFactory = new
ActiveMQConnectionFactory(BROKER_URL);
//Destination destination = client.getSession();
// Create a Connection
Connection connection = connectionFactory.createConnection();
connection.start();
// Create a Session
Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
// Create the destination (Topic or Queue)
Destination destination = session.createTopic(CHANNEL);
// Create a MessageProducer from the Session to the Topic or
Queue
MessageProducer producer = session.createProducer(destination);
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
// Create a messages
String from = Thread.currentThread().getName();
String text = "<message type='chat' from='" + from + "'>Hello
World Yo!</message>";
//String text = "Hello world! From: " +
Thread.currentThread().getName() + " : " + this.hashCode();
TextMessage message = session.createTextMessage(text);
// Tell the producer to send the message
System.out.println("Sent message: "+ message.hashCode() + " : "
+ Thread.currentThread().getName());
producer.send(message);
// Clean up
session.close();
connection.close();
--
View this message in context: http://www.nabble.com/Java-sending-message-to-listening-ajax-tf2222685.html#a6158009
Sent from the ActiveMQ - User forum at Nabble.com.
Re: Java sending message to listening ajax
Posted by Adrian Co <ac...@exist.com>.
vm://localhost will create a separate embedded broker for you that is
probably independent from the one the ajax app is using.
Refer to this thread for details:
http://www.nabble.com/app-to-web-demo-tf2193800.html#a6071268
jefetech wrote:
> This is my broker:
> private static final String BROKER_URL = "vm://localhost";
> private static final String CHANNEL = "topic://CHAT.DEMO";
>
>
> My console displays that the message was successfully sent, along with a
> message ID, however my ajax listening window does not receive it. This
> string message shoult spit out text in my Ajax listening console: <message
> type='chat' from='" + from + "'>Hello World Yo!</message>
>
> The ajax is working fine sending/receiving messages. It's just when I try
> to do it in a Java class, it won't receive it. Thank you.
>
>
>
>
>
> Adrian Co wrote:
>
>> Hi,
>>
>> You don't need to simulate an httppost, since internally the ajax
>> messaging is still using JMS. (I'm assuming that you're using the
>> activemq-web libraries :)) Are you getting any exceptions? What's your
>> broker url?
>>
>> Maybe you're running into this issue:
>> http://www.nabble.com/app-to-web-demo-tf2193800.html#a6071268
>>
>> jefetech wrote:
>>
>>> I've got all my ajax send/receive working, however I need a java program
>>> to
>>> be able to send/receive message from the ajax. Why does the ajax not
>>> receive this? Do I need simulate a httppost instead of this?
>>>
>>> ActiveMQConnectionFactory connectionFactory = new
>>> ActiveMQConnectionFactory(BROKER_URL);
>>>
>>> //Destination destination = client.getSession();
>>>
>>> // Create a Connection
>>> Connection connection = connectionFactory.createConnection();
>>> connection.start();
>>>
>>> // Create a Session
>>> Session session = connection.createSession(false,
>>> Session.AUTO_ACKNOWLEDGE);
>>>
>>>
>>> // Create the destination (Topic or Queue)
>>> Destination destination = session.createTopic(CHANNEL);
>>>
>>> // Create a MessageProducer from the Session to the Topic or
>>> Queue
>>> MessageProducer producer =
>>> session.createProducer(destination);
>>> producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
>>>
>>> // Create a messages
>>> String from = Thread.currentThread().getName();
>>> String text = "<message type='chat' from='" + from + "'>Hello
>>> World Yo!</message>";
>>> //String text = "Hello world! From: " +
>>> Thread.currentThread().getName() + " : " + this.hashCode();
>>> TextMessage message = session.createTextMessage(text);
>>>
>>> // Tell the producer to send the message
>>> System.out.println("Sent message: "+ message.hashCode() + " :
>>> "
>>> + Thread.currentThread().getName());
>>> producer.send(message);
>>>
>>> // Clean up
>>> session.close();
>>> connection.close();
>>>
>>>
>>
>>
>
>
Re: Java sending message to listening ajax
Posted by jefetech <in...@jefetech.com>.
This is my broker:
private static final String BROKER_URL = "vm://localhost";
private static final String CHANNEL = "topic://CHAT.DEMO";
My console displays that the message was successfully sent, along with a
message ID, however my ajax listening window does not receive it. This
string message shoult spit out text in my Ajax listening console: <message
type='chat' from='" + from + "'>Hello World Yo!</message>
The ajax is working fine sending/receiving messages. It's just when I try
to do it in a Java class, it won't receive it. Thank you.
Adrian Co wrote:
>
> Hi,
>
> You don't need to simulate an httppost, since internally the ajax
> messaging is still using JMS. (I'm assuming that you're using the
> activemq-web libraries :)) Are you getting any exceptions? What's your
> broker url?
>
> Maybe you're running into this issue:
> http://www.nabble.com/app-to-web-demo-tf2193800.html#a6071268
>
> jefetech wrote:
>> I've got all my ajax send/receive working, however I need a java program
>> to
>> be able to send/receive message from the ajax. Why does the ajax not
>> receive this? Do I need simulate a httppost instead of this?
>>
>> ActiveMQConnectionFactory connectionFactory = new
>> ActiveMQConnectionFactory(BROKER_URL);
>>
>> //Destination destination = client.getSession();
>>
>> // Create a Connection
>> Connection connection = connectionFactory.createConnection();
>> connection.start();
>>
>> // Create a Session
>> Session session = connection.createSession(false,
>> Session.AUTO_ACKNOWLEDGE);
>>
>>
>> // Create the destination (Topic or Queue)
>> Destination destination = session.createTopic(CHANNEL);
>>
>> // Create a MessageProducer from the Session to the Topic or
>> Queue
>> MessageProducer producer =
>> session.createProducer(destination);
>> producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
>>
>> // Create a messages
>> String from = Thread.currentThread().getName();
>> String text = "<message type='chat' from='" + from + "'>Hello
>> World Yo!</message>";
>> //String text = "Hello world! From: " +
>> Thread.currentThread().getName() + " : " + this.hashCode();
>> TextMessage message = session.createTextMessage(text);
>>
>> // Tell the producer to send the message
>> System.out.println("Sent message: "+ message.hashCode() + " :
>> "
>> + Thread.currentThread().getName());
>> producer.send(message);
>>
>> // Clean up
>> session.close();
>> connection.close();
>>
>
>
>
--
View this message in context: http://www.nabble.com/Java-sending-message-to-listening-ajax-tf2222685.html#a6162541
Sent from the ActiveMQ - User forum at Nabble.com.
Re: Java sending message to listening ajax
Posted by Adrian Co <ac...@exist.com>.
Hi,
You don't need to simulate an httppost, since internally the ajax
messaging is still using JMS. (I'm assuming that you're using the
activemq-web libraries :)) Are you getting any exceptions? What's your
broker url?
Maybe you're running into this issue:
http://www.nabble.com/app-to-web-demo-tf2193800.html#a6071268
jefetech wrote:
> I've got all my ajax send/receive working, however I need a java program to
> be able to send/receive message from the ajax. Why does the ajax not
> receive this? Do I need simulate a httppost instead of this?
>
> ActiveMQConnectionFactory connectionFactory = new
> ActiveMQConnectionFactory(BROKER_URL);
>
> //Destination destination = client.getSession();
>
> // Create a Connection
> Connection connection = connectionFactory.createConnection();
> connection.start();
>
> // Create a Session
> Session session = connection.createSession(false,
> Session.AUTO_ACKNOWLEDGE);
>
>
> // Create the destination (Topic or Queue)
> Destination destination = session.createTopic(CHANNEL);
>
> // Create a MessageProducer from the Session to the Topic or
> Queue
> MessageProducer producer = session.createProducer(destination);
> producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
>
> // Create a messages
> String from = Thread.currentThread().getName();
> String text = "<message type='chat' from='" + from + "'>Hello
> World Yo!</message>";
> //String text = "Hello world! From: " +
> Thread.currentThread().getName() + " : " + this.hashCode();
> TextMessage message = session.createTextMessage(text);
>
> // Tell the producer to send the message
> System.out.println("Sent message: "+ message.hashCode() + " : "
> + Thread.currentThread().getName());
> producer.send(message);
>
> // Clean up
> session.close();
> connection.close();
>