Styjun

Can an integer optimization problem be convex?

Cut a cake into 3 equal portions with only a knife

How can an attacker use robots.txt?

Strange Sticky Substance on Digital Camera

What is the meaning of word 'crack' in chapter 33 of A Game of Thrones?

Why weren't the Death Star plans transmitted electronically?

What's the lowest risk highest reward I can invest in for 5 years?

My manager quit. Should I agree to defer wage increase to accommodate budget concerns?

Is it really necessary to have a four hour meeting in Sprint planning?

Are Custom Indexes passed on to Sandboxes

Do we have any particular tonal center in mind when we are NOT listening music?

When is it acceptable to write a bad letter of recommendation?

How can I repair this gas leak on my new range? Teflon tape isn't working

Is it right to extend flaps only in the white arc?

Organisational search option

Is it a good idea to leave minor world details to the reader's imagination?

Designing a time thief proof safe

My Project Manager does not accept carry-over in Scrum, Is that normal?

How to deal with a Homophobic PC

Performance for simple code that converts a RGB tuple to hex string

Is the mass of paint relevant in rocket design?

What benefits does the Power Word Kill spell have?

Late 1970's and 6502 chip facilities for operating systems

Can the U.S. president make military decisions without consulting anyone?

Read AMQ queue messages without creating a new queue

Jboss 5.1 ActiveMQ 5 standalone broker MDB setupHow do I kill “ActiveMQ Transport” threads after interrupting JMS MessageConsumer.receive()JMS + Spring Integration + ActiveMQ ! Not working on JVM but working on activeMQ serverCreating consumer and temporary queue in same connection in Activemq?Unable to upgrade client from ActiveMQ 5.5.1 to ActiveMQ 5.10ActiveMQ connect to existing queue at an address/portwhat are the special characters that are not allowed during creation of activemq queue?Cannot create ActiveMQ queue or send a message using javanot able to send message to remote Tomcat and ActiveMQ queuePrevent Temp Queue auto Topic creation in ActiveMQ

.everyoneloves__top-leaderboard:empty,.everyoneloves__mid-leaderboard:empty,.everyoneloves__bot-mid-leaderboard:empty margin-bottom:0;

0

I am trying to browse messages from ActiveMQ queue using the following code. This will create a new destinationQueue on the broker if one doesn't exists. How can I avoid creating a new queue? I was expecting a JMSException if the given queue doesn't exist.

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616"); 
Connection connection = connectionFactory.createConnection("admin", "admin");
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue(destinationQueue);
QueueBrowser queueBrowser = session.createBrowser(queue);
Enumeration enumMsgs = queueBrowser.getEnumeration();

jms activemq

share|improve this question

edited Mar 29 at 21:09

Justin Bertram

6,15111 gold badge66 silver badges2424 bronze badges

asked Mar 28 at 16:35

NandanNandan

5911 gold badge22 silver badges99 bronze badges

add a comment
 | 

0

I am trying to browse messages from ActiveMQ queue using the following code. This will create a new destinationQueue on the broker if one doesn't exists. How can I avoid creating a new queue? I was expecting a JMSException if the given queue doesn't exist.

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616"); 
Connection connection = connectionFactory.createConnection("admin", "admin");
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue(destinationQueue);
QueueBrowser queueBrowser = session.createBrowser(queue);
Enumeration enumMsgs = queueBrowser.getEnumeration();

jms activemq

share|improve this question

edited Mar 29 at 21:09

Justin Bertram

6,15111 gold badge66 silver badges2424 bronze badges

asked Mar 28 at 16:35

NandanNandan

5911 gold badge22 silver badges99 bronze badges

add a comment
 | 

I am trying to browse messages from ActiveMQ queue using the following code. This will create a new destinationQueue on the broker if one doesn't exists. How can I avoid creating a new queue? I was expecting a JMSException if the given queue doesn't exist.

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616"); 
Connection connection = connectionFactory.createConnection("admin", "admin");
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue(destinationQueue);
QueueBrowser queueBrowser = session.createBrowser(queue);
Enumeration enumMsgs = queueBrowser.getEnumeration();

jms activemq

share|improve this question

edited Mar 29 at 21:09

Justin Bertram

6,15111 gold badge66 silver badges2424 bronze badges

asked Mar 28 at 16:35

NandanNandan

5911 gold badge22 silver badges99 bronze badges

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616"); 
Connection connection = connectionFactory.createConnection("admin", "admin");
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue(destinationQueue);
QueueBrowser queueBrowser = session.createBrowser(queue);
Enumeration enumMsgs = queueBrowser.getEnumeration();

share|improve this question

edited Mar 29 at 21:09

Justin Bertram

6,15111 gold badge66 silver badges2424 bronze badges

asked Mar 28 at 16:35

NandanNandan

5911 gold badge22 silver badges99 bronze badges

share|improve this question

edited Mar 29 at 21:09

Justin Bertram

6,15111 gold badge66 silver badges2424 bronze badges

asked Mar 28 at 16:35

NandanNandan

5911 gold badge22 silver badges99 bronze badges

edited Mar 29 at 21:09

Justin Bertram

6,15111 gold badge66 silver badges2424 bronze badges

edited Mar 29 at 21:09

Justin Bertram

6,15111 gold badge66 silver badges2424 bronze badges

asked Mar 28 at 16:35

NandanNandan

5911 gold badge22 silver badges99 bronze badges

asked Mar 28 at 16:35

NandanNandan

5911 gold badge22 silver badges99 bronze badges

2 Answers
2

active

oldest

votes

1

See the ActiveMQ documentation on this subject:

As is described in How do I create new destinations there is no need to create all the destinations up front, you can let the broker create them on the fly.

However if you don't want this behaviour, or wish to restrict this behaviour to certain topic or queue Wildcards (areas of the queue or topic name space) then you can use the Security plugins to disallow the admin role on whatever areas of the queue and topic namespace you wish

share|improve this answer

answered Mar 28 at 16:49

Justin BertramJustin Bertram

6,15111 gold badge66 silver badges2424 bronze badges

add a comment
 | 

0

Its a live system and unfortunately I have no access to its security settings or another user. But found a work around,
I fetched the collection of queues by the following code and validated the 'destinationQueue'[provided Queue name for browsing] with the collection before creating 'QueueBrowser'

 ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
 ActiveMQConnection connection = (ActiveMQConnection)connectionFactory.createConnection("admin","admin");
 connection.start();
 DestinationSource ds = connection.getDestinationSource();
 Set<ActiveMQQueue> queues = ds.getQueues();
 for (ActiveMQQueue queue : queues) 
 if (destinationQueue.equals(queue.getPhysicalName())) 
 queueExists = true;
 

 

share|improve this answer

answered Apr 1 at 11:18

NandanNandan

5911 gold badge22 silver badges99 bronze badges

add a comment
 | 

Your Answer

StackExchange.ifUsing("editor", function ()
StackExchange.using("externalEditor", function ()
StackExchange.using("snippets", function ()
StackExchange.snippets.init();
);
);
, "code-snippets");

StackExchange.ready(function()
var channelOptions =
tags: "".split(" "),
id: "1"
;
initTagRenderer("".split(" "), "".split(" "), channelOptions);

StackExchange.using("externalEditor", function()
// Have to fire editor after snippets, if snippets enabled
if (StackExchange.settings.snippets.snippetsEnabled)
StackExchange.using("snippets", function()
createEditor();
);

else
createEditor();

);

function createEditor()
StackExchange.prepareEditor(
heartbeatType: 'answer',
autoActivateHeartbeat: false,
convertImagesToLinks: true,
noModals: true,
showLowRepImageUploadWarning: true,
reputationToPostImages: 10,
bindNavPrevention: true,
postfix: "",
imageUploader:
brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/4.0/"u003ecc by-sa 4.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
allowUrls: true
,
onDemand: true,
discardSelector: ".discard-answer"
,immediatelyShowMarkdownHelp:true
);



);

draft saved

draft discarded

Sign up or log in

StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);

Sign up using Google

Sign up using Facebook

Sign up using Email and Password

Post as a guest

Name

Email

Required, but never shown

StackExchange.ready(
function ()
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f55402722%2fread-amq-queue-messages-without-creating-a-new-queue%23new-answer', 'question_page');

);

Post as a guest

Name

Email

Required, but never shown

1

See the ActiveMQ documentation on this subject:

As is described in How do I create new destinations there is no need to create all the destinations up front, you can let the broker create them on the fly.

However if you don't want this behaviour, or wish to restrict this behaviour to certain topic or queue Wildcards (areas of the queue or topic name space) then you can use the Security plugins to disallow the admin role on whatever areas of the queue and topic namespace you wish

share|improve this answer

answered Mar 28 at 16:49

Justin BertramJustin Bertram

6,15111 gold badge66 silver badges2424 bronze badges

add a comment
 | 

1

See the ActiveMQ documentation on this subject:

As is described in How do I create new destinations there is no need to create all the destinations up front, you can let the broker create them on the fly.

However if you don't want this behaviour, or wish to restrict this behaviour to certain topic or queue Wildcards (areas of the queue or topic name space) then you can use the Security plugins to disallow the admin role on whatever areas of the queue and topic namespace you wish

share|improve this answer

answered Mar 28 at 16:49

Justin BertramJustin Bertram

6,15111 gold badge66 silver badges2424 bronze badges

add a comment
 | 

See the ActiveMQ documentation on this subject:

As is described in How do I create new destinations there is no need to create all the destinations up front, you can let the broker create them on the fly.

However if you don't want this behaviour, or wish to restrict this behaviour to certain topic or queue Wildcards (areas of the queue or topic name space) then you can use the Security plugins to disallow the admin role on whatever areas of the queue and topic namespace you wish

share|improve this answer

answered Mar 28 at 16:49

Justin BertramJustin Bertram

6,15111 gold badge66 silver badges2424 bronze badges

share|improve this answer

answered Mar 28 at 16:49

Justin BertramJustin Bertram

6,15111 gold badge66 silver badges2424 bronze badges

answered Mar 28 at 16:49

Justin BertramJustin Bertram

6,15111 gold badge66 silver badges2424 bronze badges

answered Mar 28 at 16:49

Justin BertramJustin Bertram

6,15111 gold badge66 silver badges2424 bronze badges

0

Its a live system and unfortunately I have no access to its security settings or another user. But found a work around,
I fetched the collection of queues by the following code and validated the 'destinationQueue'[provided Queue name for browsing] with the collection before creating 'QueueBrowser'

 ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
 ActiveMQConnection connection = (ActiveMQConnection)connectionFactory.createConnection("admin","admin");
 connection.start();
 DestinationSource ds = connection.getDestinationSource();
 Set<ActiveMQQueue> queues = ds.getQueues();
 for (ActiveMQQueue queue : queues) 
 if (destinationQueue.equals(queue.getPhysicalName())) 
 queueExists = true;
 

 

share|improve this answer

answered Apr 1 at 11:18

NandanNandan

5911 gold badge22 silver badges99 bronze badges

add a comment
 | 

0

Its a live system and unfortunately I have no access to its security settings or another user. But found a work around,
I fetched the collection of queues by the following code and validated the 'destinationQueue'[provided Queue name for browsing] with the collection before creating 'QueueBrowser'

 ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
 ActiveMQConnection connection = (ActiveMQConnection)connectionFactory.createConnection("admin","admin");
 connection.start();
 DestinationSource ds = connection.getDestinationSource();
 Set<ActiveMQQueue> queues = ds.getQueues();
 for (ActiveMQQueue queue : queues) 
 if (destinationQueue.equals(queue.getPhysicalName())) 
 queueExists = true;
 

 

share|improve this answer

answered Apr 1 at 11:18

NandanNandan

5911 gold badge22 silver badges99 bronze badges

add a comment
 | 

Its a live system and unfortunately I have no access to its security settings or another user. But found a work around,
I fetched the collection of queues by the following code and validated the 'destinationQueue'[provided Queue name for browsing] with the collection before creating 'QueueBrowser'

 ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
 ActiveMQConnection connection = (ActiveMQConnection)connectionFactory.createConnection("admin","admin");
 connection.start();
 DestinationSource ds = connection.getDestinationSource();
 Set<ActiveMQQueue> queues = ds.getQueues();
 for (ActiveMQQueue queue : queues) 
 if (destinationQueue.equals(queue.getPhysicalName())) 
 queueExists = true;
 

 

share|improve this answer

answered Apr 1 at 11:18

NandanNandan

5911 gold badge22 silver badges99 bronze badges

 ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
 ActiveMQConnection connection = (ActiveMQConnection)connectionFactory.createConnection("admin","admin");
 connection.start();
 DestinationSource ds = connection.getDestinationSource();
 Set<ActiveMQQueue> queues = ds.getQueues();
 for (ActiveMQQueue queue : queues) 
 if (destinationQueue.equals(queue.getPhysicalName())) 
 queueExists = true;
 

 

share|improve this answer

answered Apr 1 at 11:18

NandanNandan

5911 gold badge22 silver badges99 bronze badges

answered Apr 1 at 11:18

NandanNandan

5911 gold badge22 silver badges99 bronze badges

answered Apr 1 at 11:18

NandanNandan

5911 gold badge22 silver badges99 bronze badges