activemq-cpp-3.9.5
OpenWireFormatNegotiator.h
Go to the documentation of this file.
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
18#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_OPENWIREFORMATNEGOTIATOR_H_
19#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_OPENWIREFORMATNEGOTIATOR_H_
20
29#include <decaf/lang/Pointer.h>
30
31namespace activemq{
32namespace wireformat{
33namespace openwire{
34
35 using decaf::lang::Pointer;
36
37 class AMQCPP_API OpenWireFormatNegotiator: public wireformat::WireFormatNegotiator {
38 private:
39
43 static const int negotiationTimeout;
44
49
53 decaf::util::concurrent::CountDownLatch wireInfoSentDownLatch;
55
59 OpenWireFormat* openWireFormat;
60
61 private:
62
63 OpenWireFormatNegotiator(const OpenWireFormatNegotiator&);
64 OpenWireFormatNegotiator& operator=(const OpenWireFormatNegotiator&);
65
66 public:
67
74
76
77 virtual void oneway(const Pointer<commands::Command> command);
78
80
81 virtual Pointer<commands::Response> request(const Pointer<commands::Command> command, unsigned int timeout);
82
83 public:
84
85 virtual void onCommand(const Pointer<commands::Command> command);
86
87 virtual void onException(const decaf::lang::Exception& ex);
88
89 protected:
90
91 virtual void afterNextIsStarted();
92
93 virtual void afterNextIsStopped();
94
95 };
96
97}}}
98
99#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_OPENWIREFORMATNEGOTIATOR_H_*/
#define AMQCPP_API
Definition Config.h:30
Pointer< Transport > next
The transport that this filter wraps around.
Definition TransportFilter.h:54
Defines a WireFormatNegotiator which allows a WireFormat to.
Definition WireFormatNegotiator.h:33
virtual void onCommand(const Pointer< commands::Command > command)
Event handler for the receipt of a command.
virtual void afterNextIsStopped()
Subclasses can override this method to do their own stop work.
OpenWireFormatNegotiator(OpenWireFormat *wireFormat, const Pointer< transport::Transport > next)
Constructor - Initializes this object around another Transport.
virtual void afterNextIsStarted()
Subclasses can override this method to do their own post startup work.
virtual Pointer< commands::Response > request(const Pointer< commands::Command > command, unsigned int timeout)
Sends the given command to the broker and then waits for the response.
virtual void oneway(const Pointer< commands::Command > command)
Sends a one-way command.
virtual Pointer< commands::Response > request(const Pointer< commands::Command > command)
Sends the given command to the broker and then waits for the response.
virtual void onException(const decaf::lang::Exception &ex)
Event handler for an exception from a command transport.
Definition Exception.h:38
Decaf's implementation of a Smart Pointer that is a template on a Type and is Thread Safe if the defa...
Definition Pointer.h:53
Definition CountDownLatch.h:33
A boolean value that may be updated atomically.
Definition AtomicBoolean.h:34
Definition BaseDataStreamMarshaller.h:30
Definition BaseDataStructure.h:28
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
Definition CachedConsumer.h:24