Examples of org.apache.activemq.ActiveMQConnection.createSession()

Class org.apache.activemq.ActiveMQConnection

Examples of org.apache.activemq.ActiveMQConnection.createSession()

org.apache.activemq.ActiveMQConnection.createSession()
Creates a Session object. @param transacted indicates whether the session is transacted @param acknowledgeMode indicates whether the consumer or the client willacknowledge any messages it receives; ignored if the session is transacted. Legal values are Session.AUTO_ACKNOWLEDGE, Session.CLIENT_ACKNOWLEDGE, and Session.DUPS_OK_ACKNOWLEDGE. @return a newly created session @throws JMSException if the Connection object fails tocreate a session due to some internal error or lack of support for the specific transaction and acknowledgement mode. @see Session#AUTO_ACKNOWLEDGE @see Session#CLIENT_ACKNOWLEDGE @see Session#DUPS_OK_ACKNOWLEDGE @since 1.1


    private void send10000messages(CountDownLatch latch) {
        ActiveMQConnection activeMQConnection = null;
        try {
            activeMQConnection = createConnection(null);
            Session session = activeMQConnection.createSession(false,
                    Session.AUTO_ACKNOWLEDGE);
            MessageProducer producer = session.createProducer(session
                    .createQueue(queueName));
            producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
            activeMQConnection.start();

View Full Code Here


    private void receiveAndDiscard100messages(CountDownLatch latch) {
        ActiveMQConnection activeMQConnection = null;
        try {
            activeMQConnection = createConnection(null);
            Session session = activeMQConnection.createSession(false,
                    Session.AUTO_ACKNOWLEDGE);
            MessageConsumer messageConsumer = session.createConsumer(
                    session.createQueue(queueName));
            activeMQConnection.start();
            for (int i = 0; i < 100; i++) {

View Full Code Here


    private void send10000messages(CountDownLatch latch) {
        ActiveMQConnection activeMQConnection = null;
        try {
            activeMQConnection = createConnection(null);
            Session session = activeMQConnection.createSession(false,
                    Session.AUTO_ACKNOWLEDGE);
            MessageProducer producer = session.createProducer(session
                    .createQueue(queueName));
            producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
            activeMQConnection.start();

View Full Code Here


    private void receiveAndDiscard100messages(CountDownLatch latch) {
        ActiveMQConnection activeMQConnection = null;
        try {
            activeMQConnection = createConnection(null);
            Session session = activeMQConnection.createSession(false,
                    Session.AUTO_ACKNOWLEDGE);
            MessageConsumer messageConsumer = session.createConsumer(
                    session.createQueue(queueName));
            activeMQConnection.start();
            for (int i = 0; i < 100; i++) {

View Full Code Here

    public void testZeroPrefetchConsumerIsAborted() throws Exception {
        ActiveMQConnection conn = (ActiveMQConnection) createConnectionFactory().createConnection();
        conn.setExceptionListener(this);
        connections.add(conn);


        Session sess = conn.createSession(false, Session.CLIENT_ACKNOWLEDGE);
        final MessageConsumer consumer = sess.createConsumer(destination);
        assertNotNull(consumer);
        conn.start();
        startProducers(destination, 20);

View Full Code Here


        ActiveMQConnection conn = (ActiveMQConnection) createConnectionFactory().createConnection();
        conn.setExceptionListener(this);
        connections.add(conn);


        Session sess = conn.createSession(false, Session.CLIENT_ACKNOWLEDGE);
        final MessageConsumer consumer = sess.createConsumer(destination);
        assertNotNull(consumer);
        conn.start();
        startProducers(destination, 20);

View Full Code Here


        ActiveMQConnection conn = (ActiveMQConnection) createConnectionFactory().createConnection();
        conn.setExceptionListener(this);
        connections.add(conn);


        Session sess = conn.createSession(false, Session.CLIENT_ACKNOWLEDGE);
        final MessageConsumer consumer = sess.createConsumer(destination);
        assertNotNull(consumer);
        conn.start();
        startProducers(destination, 20);

View Full Code Here

        service.execute(new Runnable() {
            @Override
            public void run() {
                try {
                    ActiveMQConnection connection = (ActiveMQConnection) cf.createConnection();
                    Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
                    Destination destination = session.createTemporaryQueue();
                    MessageProducer producer = session.createProducer(destination);
                    producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
                    producer.setTimeToLive(400);
                    producer.send(session.createTextMessage());

View Full Code Here

        service.execute(new Runnable() {
            @Override
            public void run() {
                try {
                    ActiveMQConnection connection = (ActiveMQConnection) cf.createConnection();
                    Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
                    Destination destination = session.createTemporaryQueue();
                    MessageProducer producer = session.createProducer(destination);
                    producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
                    producer.setTimeToLive(400);
                    producer.send(session.createTextMessage());

View Full Code Here

    public void testNonBlockingMessageDeleiveryIsDelayed() throws Exception {
        final LinkedHashSet<Message> received = new LinkedHashSet<Message>();


        ActiveMQConnection connection = (ActiveMQConnection) connectionFactory.createConnection();
        connection.getRedeliveryPolicy().setInitialRedeliveryDelay(TimeUnit.SECONDS.toMillis(6));
        Session session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
        Destination destination = session.createQueue(destinationName);
        MessageConsumer consumer = session.createConsumer(destination);


        consumer.setMessageListener(new MessageListener() {
            @Override

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

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.