CommandVisitor


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