Commit 6fab6dd6 authored by Nicolas Tachker's avatar Nicolas Tachker
Browse files

change destinations name (use classic admin to create destinations).

parent 8b59e0e4
......@@ -51,10 +51,9 @@ public class Connector {
ja.start(bt);
System.out.println("start ...");
Context ictx = new InitialContext();
Queue queue = (Queue) ictx.lookup("sampleQueue");
Topic topic = (Topic) ictx.lookup("sampleTopic");
Queue queue = (Queue) ictx.lookup("queue");
Topic topic = (Topic) ictx.lookup("topic");
ictx.close();
......@@ -94,13 +93,13 @@ public class Connector {
ActivationSpecImpl spec = new ActivationSpecImpl();
spec.setResourceAdapter(ja);
spec.setDestinationType("javax.jms.Queue");
spec.setDestination("sampleQueue");
spec.setDestination("queue");
MessagePointFactory mep2 = new MessagePointFactory();
ActivationSpecImpl spec2 = new ActivationSpecImpl();
spec2.setResourceAdapter(ja);
spec2.setDestinationType("javax.jms.Topic");
spec2.setDestination("sampleTopic");
spec2.setDestination("topic");
ja.endpointActivation(mep , spec); // listener on queue
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment