Examples of org.activemq.message.ActiveMQQueue

org.activemq.message.ActiveMQQueue
A Queue object encapsulates a provider-specific queue name. It is the way a client specifies the identity of a queue to JMS API methods. For those methods that use a Destination as a parameter, a Queue object used as an argument. For example, a queue can be used to create a MessageConsumer and a MessageProducer by calling:
- Session.CreateConsumer(Destination destination)
- Session.CreateProducer(Destination destination)
The actual length of time messages are held by a queue and the consequences of resource overflow are not defined by the JMS API. @see javax.jms.Session#createConsumer(javax.jms.Destination) @see javax.jms.Session#createProducer(javax.jms.Destination) @see javax.jms.Session#createQueue(String) @see javax.jms.QueueSession#createQueue(String)

        destinationMap.removeAll(dest);
    }


    public void sendToDeadLetterQueue(String deadLetterName, ActiveMQMessage message) throws JMSException {
        
        ActiveMQQueue destination = new ActiveMQQueue(deadLetterName);
        DurableQueueBoundedMessageContainer container = (DurableQueueBoundedMessageContainer) containers.get(destination);
        if (container == null) {
            container = createContainer(destination, true);
        }        
        container.enqueue(message);

View Full Code Here

    /**
     * @see junit.framework.TestCase#setUp()
     */
    protected void setUp() throws Exception {
        factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
        this.target = new ActiveMQQueue(getClass().getName());
    }

View Full Code Here


        ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("vm://localhost");


        factory.setUseEmbeddedBroker(true);
        connection = factory.createConnection();
        queue = new ActiveMQQueue(getClass().getName() + "." + getName());


        producerSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        consumerSession = connection.createSession(true, 0);


        producer = producerSession.createProducer(queue);

View Full Code Here

    protected Destination createDestination(String name) {
        if (topic) {
            return new ActiveMQTopic(name);
        }
        else {
            return new ActiveMQQueue(name);
        }
    }

View Full Code Here

        if (name != null) {
            if (defaultTopicFlag) {
                defaultDestination = new ActiveMQTopic(name);
            }
            else {
                defaultDestination = new ActiveMQQueue(name);
            }
        }


        // lets check to see if there's a connection factory set
        WebClient.initContext(getServletContext());

View Full Code Here

     * @throws JMSException if the destination cannot be created
     */
    public void createDestination(String name, boolean queue)
            throws JMSException {
        if (queue) {
          directory.put(name, new ActiveMQQueue(name));
        }
        else {
          directory.put(name, new ActiveMQTopic(name));
        }
    }

View Full Code Here


    public ActiveMQDestination createDestination() {
        ActiveMQDestination dest = null;
        if (isValidDestinationType() && isValidDestination()) {
            if (Queue.class.getName().equals(destinationType)) {
                dest = new ActiveMQQueue(destination);
            } else if (Topic.class.getName().equals(destinationType)) {
                dest = new ActiveMQTopic(destination);
            } else {
                assert false : "Execution should never reach here";
            }

View Full Code Here

                workers.returnObject(new InboundEndpointWork((ActiveMQSession) session, endpoint, workers));
            }


            Destination dest = null;
            if ("javax.jms.Queue".equals(activationSpec.getDestinationType())) {
                dest = new ActiveMQQueue(activationSpec.getDestination());
            }
            else if ("javax.jms.Topic".equals(activationSpec.getDestinationType())) {
                dest = new ActiveMQTopic(activationSpec.getDestination());
            }
            else {

View Full Code Here

            }
        };


        ActiveMQActivationSpec activationSpec = endpointActivationKey.getActivationSpec();
        if ("javax.jms.Queue".equals(activationSpec.getDestinationType())) {
            dest = new ActiveMQQueue(activationSpec.getDestination());
        } else if ("javax.jms.Topic".equals(activationSpec.getDestinationType())) {
            dest = new ActiveMQTopic(activationSpec.getDestination());
        } else {
            throw new ResourceException("Unknown destination type: " + activationSpec.getDestinationType());
        }

View Full Code Here

            consumerInfo.setConsumerId(idGenerator.generateId());
            consumerInfo.setStarted(true);
            client.consumeConsumerInfo(consumerInfo);


            consumerInfo = new ConsumerInfo();
            consumerInfo.setDestination(new ActiveMQQueue(">"));
            consumerInfo.setNoLocal(true);
            consumerInfo.setClientId(brokerClientID);
            consumerInfo.setConsumerId(idGenerator.generateId());
            consumerInfo.setStarted(true);
            client.consumeConsumerInfo(consumerInfo);

View Full Code Here

0 1 2 3 4 5 6

TOP

Related Classes of org.activemq.message.ActiveMQQueue

JMSClient

org.activemq.ActiveMQConnectionFactory

org.activemq.ActiveMQSession

org.activemq.broker.BrokerAdminTest

org.activemq.io.impl.ActiveMQMessageReaderTest

org.activemq.JmsSessionRecoverTest

org.activemq.jndi.ActiveMQInitialContextFactory

org.activemq.jndi.ActiveMQInitialContextFactoryTest

org.activemq.LargeMessageTestSupport

org.activemq.management.JMSQueueStatsImpl

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.