KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > apache > activemq > command > MessageDispatchNotification


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.command;
19
20 import org.apache.activemq.state.CommandVisitor;
21
22 /**
23  *
24  * @openwire:marshaller code="90"
25  * @version $Revision$
26  */
27 public class MessageDispatchNotification extends BaseCommand{
28
29     public static final byte DATA_STRUCTURE_TYPE=CommandTypes.MESSAGE_DISPATCH_NOTIFICATION;
30
31     protected ConsumerId consumerId;
32     protected ActiveMQDestination destination;
33     protected MessageId messageId;
34     protected long deliverySequenceId;
35
36     public byte getDataStructureType(){
37         return DATA_STRUCTURE_TYPE;
38     }
39
40     public boolean isMessageDispatchNotification(){
41         return true;
42     }
43
44     /**
45      * @openwire:property version=1 cache=true
46      */
47     public ConsumerId getConsumerId(){
48         return consumerId;
49     }
50     public void setConsumerId(ConsumerId consumerId){
51         this.consumerId=consumerId;
52     }
53
54     /**
55      * @openwire:property version=1 cache=true
56      */
57     public ActiveMQDestination getDestination(){
58         return destination;
59     }
60     public void setDestination(ActiveMQDestination destination){
61         this.destination=destination;
62     }
63
64     /**
65      * @openwire:property version=1
66      */
67
68     public long getDeliverySequenceId(){
69         return deliverySequenceId;
70     }
71     public void setDeliverySequenceId(long deliverySequenceId){
72         this.deliverySequenceId=deliverySequenceId;
73     }
74
75     public Response visit(CommandVisitor visitor) throws Exception JavaDoc {
76         return visitor.processMessageDispatchNotification( this );
77     }
78     
79
80     /**
81      * @openwire:property version=1
82      */
83     public MessageId getMessageId(){
84         return messageId;
85     }
86
87     public void setMessageId(MessageId messageId){
88         this.messageId=messageId;
89     }
90
91 }
92
Popular Tags