List of txSelect() Examples

Examples of txSelect()

com.rabbitmq.client.Channel.txSelect()
Enables TX mode on this channel. @see com.rabbitmq.client.AMQP.Tx.Select @see com.rabbitmq.client.AMQP.Tx.SelectOk @return a transaction-selection method to indicate the transaction was successfully initiated @throws java.io.IOException if an error is encountered
org.apache.qpid.transport.Session.txSelect()

Examples of com.rabbitmq.client.Channel.txSelect()

    }


    @Override
    protected Channel provideChannel() throws IOException {
        Channel channel = super.provideChannel();
        channel.txSelect();
        return  channel;
    }


    static void commitTransaction(Channel channel) throws IOException {
        try {

View Full Code Here

Examples of com.rabbitmq.client.Channel.txSelect()

      for (int i = 0; i < consumerCount; i++) {
        System.out.println("starting consumer #" + i);
        Connection conn = consumerConnections[i%connectionCount];
        Channel channel = conn.createChannel();
        if (consumerTxSize > 0)
          channel.txSelect();
        channel.exchangeDeclare(exchangeName, exchangeType);
        String queueName = channel.queueDeclare("", flags.contains("persistent"), true, false, null).getQueue();
        QueueingConsumer consumer = new QueueingConsumer(channel);
        if (prefetchCount > 0)
          channel.basicQos(prefetchCount);

View Full Code Here

Examples of com.rabbitmq.client.Channel.txSelect()

        System.out.println("starting producer #" + i);
        Connection conn = factory.newConnection();
        producerConnections[i] = conn;
        Channel channel = conn.createChannel();
        if (producerTxSize > 0)
          channel.txSelect();
        channel.exchangeDeclare(exchangeName, exchangeType);
        final Producer p = new Producer(channel, exchangeName, id, flags, producerTxSize,
            1000L * samplingInterval, rateLimit, minMsgSize, timeLimit, messageCount);
        channel.addReturnListener(p);
        Thread t = new Thread(p);

View Full Code Here

Examples of com.rabbitmq.client.Channel.txSelect()

    ccf.setChannelCacheSize(1);


    Connection con = ccf.createConnection();


    Channel channel1 = con.createChannel(true);
    channel1.txSelect();
    channel1.close(); // should be ignored, and add last into channel cache.
    /*
     * When a channel is created as non-transactional we should create a new one.
     */
    Channel channel2 = con.createChannel(false);

View Full Code Here

Examples of com.rabbitmq.client.Channel.txSelect()

  public Channel createChannel(boolean transactional) {
    try {
      Channel channel = delegate.createChannel();
      if (transactional) {
        // Just created so we want to start the transaction
        channel.txSelect();
      }
      return channel;
    } catch (IOException e) {
      throw RabbitExceptionTranslator.convertRabbitAccessException(e);
    }

View Full Code Here

Examples of org.apache.qpid.transport.Session.txSelect()

        {
            qpidSession = _qpidConnection.createSession(_name,1);
        }
        if (isTransacted())
        {
            qpidSession.txSelect();
            qpidSession.setTransacted(true);
        }
        qpidSession.setSessionListener(this);


        return qpidSession;

View Full Code Here

Examples of org.apache.qpid.transport.Session.txSelect()

        {
            qpidSession = _qpidConnection.createSession(_name,1);
        }
        if (isTransacted())
        {
            qpidSession.txSelect();
            qpidSession.setTransacted(true);
        }
        qpidSession.setSessionListener(this);


        return qpidSession;

View Full Code Here

Examples of org.apache.qpid.transport.Session.txSelect()

        {
            qpidSession = _qpidConnection.createSession(_name,1);
        }
        if (isTransacted())
        {
            qpidSession.txSelect();
            qpidSession.setTransacted(true);
        }
        qpidSession.setSessionListener(this);


        return qpidSession;

View Full Code Here

0 1

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.