Examples of org.codehaus.activemq.message.ActiveMQQueue

org.codehaus.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)

            }
        };


        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.setId(consumerInfo.getConsumerId());
            consumerInfo.setStarted(true);
            client.consumeConsumerInfo(consumerInfo);


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

View Full Code Here


    /**
     * Factory method to create new Queue instances
     */
    protected Queue createQueue(String name) {
        return new ActiveMQQueue(name);
    }

View Full Code Here


    public void testMessageAreConsumed() throws CreateException, RemoteException, NamingException, JMSException {
        InitialContext ctx = createInitialContext();
        MessengerHome home = (MessengerHome) ctx.lookup(MESSENGERBEAN_JNDI);
        MessengerObject messenger = home.create();
        ActiveMQQueue queue = new ActiveMQQueue("testMessageAreConsumed");
        
        messenger.sendMessage(queue, "Test:1");
        String msg = messenger.receiveMessage(queue, 10000);
        assertEquals("Test:1", msg);

View Full Code Here

     * @throws JMSException if the session fails to create a queue due to some internal error.
     * @since 1.1
     */
    public Queue createQueue(String queueName) throws JMSException {
        checkClosed();
        return new ActiveMQQueue(queueName);
    }

View Full Code Here

            consumerInfo.setId(consumerInfo.getConsumerId());
            consumerInfo.setStarted(true);
            client.consumeConsumerInfo(consumerInfo);


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

View Full Code Here

            ActiveMQActivationSpec activationSpec = endpointActivationKey.getActivationSpec();


            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


    /**
     * Factory method to create new Queue instances
     */
    protected Queue createQueue(String name) {
        return new ActiveMQQueue(name);
    }

View Full Code Here

                workers.returnObject(new InboundEndpointWork(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

            connection = null;
        }
    }


    public void testQueueSynchRecover() throws JMSException, InterruptedException {
        dest = new ActiveMQQueue("Queue-"+System.currentTimeMillis());
        doTestSynchRecover();
    }

View Full Code Here

0 1 2 3 4 5 6

TOP

Related Classes of org.codehaus.activemq.message.ActiveMQQueue

org.activemq.itests.OutboundResourceAdapterTest

org.codehaus.activemq.ActiveMQConnectionFactory

org.codehaus.activemq.ActiveMQSession

org.codehaus.activemq.broker.BrokerAdminTest

org.codehaus.activemq.JmsSessionRecoverTest

org.codehaus.activemq.jndi.ActiveMQInitialContextFactory

org.codehaus.activemq.LargeMessageTestSupport

org.codehaus.activemq.management.JMSQueueStatsImpl

org.codehaus.activemq.ra.ActiveMQActivationSpec

org.codehaus.activemq.ra.ActiveMQAsfEndpointWorker

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.