Home » activemq-parent-5.3.1-source-release » org.apache » activemq » state » [javadoc | source]

    1   /**
    2    * Licensed to the Apache Software Foundation (ASF) under one or more
    3    * contributor license agreements.  See the NOTICE file distributed with
    4    * this work for additional information regarding copyright ownership.
    5    * The ASF licenses this file to You under the Apache License, Version 2.0
    6    * (the "License"); you may not use this file except in compliance with
    7    * the License.  You may obtain a copy of the License at
    8    *
    9    *      http://www.apache.org/licenses/LICENSE-2.0
   10    *
   11    * Unless required by applicable law or agreed to in writing, software
   12    * distributed under the License is distributed on an "AS IS" BASIS,
   13    * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   14    * See the License for the specific language governing permissions and
   15    * limitations under the License.
   16    */
   17   package org.apache.activemq.state;
   18   
   19   import org.apache.activemq.command.BrokerInfo;
   20   import org.apache.activemq.command.ConnectionControl;
   21   import org.apache.activemq.command.ConnectionError;
   22   import org.apache.activemq.command.ConnectionId;
   23   import org.apache.activemq.command.ConnectionInfo;
   24   import org.apache.activemq.command.ConsumerControl;
   25   import org.apache.activemq.command.ConsumerId;
   26   import org.apache.activemq.command.ConsumerInfo;
   27   import org.apache.activemq.command.ControlCommand;
   28   import org.apache.activemq.command.DestinationInfo;
   29   import org.apache.activemq.command.FlushCommand;
   30   import org.apache.activemq.command.KeepAliveInfo;
   31   import org.apache.activemq.command.Message;
   32   import org.apache.activemq.command.MessageAck;
   33   import org.apache.activemq.command.MessageDispatch;
   34   import org.apache.activemq.command.MessageDispatchNotification;
   35   import org.apache.activemq.command.MessagePull;
   36   import org.apache.activemq.command.ProducerAck;
   37   import org.apache.activemq.command.ProducerId;
   38   import org.apache.activemq.command.ProducerInfo;
   39   import org.apache.activemq.command.RemoveSubscriptionInfo;
   40   import org.apache.activemq.command.Response;
   41   import org.apache.activemq.command.SessionId;
   42   import org.apache.activemq.command.SessionInfo;
   43   import org.apache.activemq.command.ShutdownInfo;
   44   import org.apache.activemq.command.TransactionInfo;
   45   import org.apache.activemq.command.WireFormatInfo;
   46   
   47   public interface CommandVisitor {
   48   
   49       Response processAddConnection(ConnectionInfo info) throws Exception;
   50   
   51       Response processAddSession(SessionInfo info) throws Exception;
   52   
   53       Response processAddProducer(ProducerInfo info) throws Exception;
   54   
   55       Response processAddConsumer(ConsumerInfo info) throws Exception;
   56   
   57       Response processRemoveConnection(ConnectionId id, long lastDeliveredSequenceId) throws Exception;
   58   
   59       Response processRemoveSession(SessionId id, long lastDeliveredSequenceId) throws Exception;
   60   
   61       Response processRemoveProducer(ProducerId id) throws Exception;
   62   
   63       Response processRemoveConsumer(ConsumerId id, long lastDeliveredSequenceId) throws Exception;
   64   
   65       Response processAddDestination(DestinationInfo info) throws Exception;
   66   
   67       Response processRemoveDestination(DestinationInfo info) throws Exception;
   68   
   69       Response processRemoveSubscription(RemoveSubscriptionInfo info) throws Exception;
   70   
   71       Response processMessage(Message send) throws Exception;
   72   
   73       Response processMessageAck(MessageAck ack) throws Exception;
   74   
   75       Response processMessagePull(MessagePull pull) throws Exception;
   76   
   77       Response processBeginTransaction(TransactionInfo info) throws Exception;
   78   
   79       Response processPrepareTransaction(TransactionInfo info) throws Exception;
   80   
   81       Response processCommitTransactionOnePhase(TransactionInfo info) throws Exception;
   82   
   83       Response processCommitTransactionTwoPhase(TransactionInfo info) throws Exception;
   84   
   85       Response processRollbackTransaction(TransactionInfo info) throws Exception;
   86   
   87       Response processWireFormat(WireFormatInfo info) throws Exception;
   88   
   89       Response processKeepAlive(KeepAliveInfo info) throws Exception;
   90   
   91       Response processShutdown(ShutdownInfo info) throws Exception;
   92   
   93       Response processFlush(FlushCommand command) throws Exception;
   94   
   95       Response processBrokerInfo(BrokerInfo info) throws Exception;
   96   
   97       Response processRecoverTransactions(TransactionInfo info) throws Exception;
   98   
   99       Response processForgetTransaction(TransactionInfo info) throws Exception;
  100   
  101       Response processEndTransaction(TransactionInfo info) throws Exception;
  102   
  103       Response processMessageDispatchNotification(MessageDispatchNotification notification) throws Exception;
  104   
  105       Response processProducerAck(ProducerAck ack) throws Exception;
  106   
  107       Response processMessageDispatch(MessageDispatch dispatch) throws Exception;
  108   
  109       Response processControlCommand(ControlCommand command) throws Exception;
  110   
  111       Response processConnectionError(ConnectionError error) throws Exception;
  112   
  113       Response processConnectionControl(ConnectionControl control) throws Exception;
  114   
  115       Response processConsumerControl(ConsumerControl control) throws Exception;
  116   
  117   }

Home » activemq-parent-5.3.1-source-release » org.apache » activemq » state » [javadoc | source]