Package deltix.qsrv.hf.tickdb.comm

Class TopicProtocol

java.lang.Object

deltix.qsrv.hf.tickdb.comm.TopicProtocol

@ParametersAreNonnullByDefault
public class TopicProtocol
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
static int	SINGLE_PUBLISHER_TOPIC_SUPPORT_VERSION

Constructor Summary

Constructors

Constructor	Description
TopicProtocol()

Method Summary

Modifier and Type	Method	Description
static AddTopicPublisherRequest	readAddTopicPublisherRequest(java.io.DataInputStream in)
static AddTopicPublisherResponse	readAddTopicPublisherResponse(java.io.DataInputStream in, int serverVersion)
static AddTopicSubscriberRequest	readAddTopicSubscriberRequest(java.io.DataInputStream in)
static AddTopicSubscriberResponse	readAddTopicSubscriberResponse(java.io.DataInputStream in)
static CreateCustomTopicRequest	readCreateCustomTopicRequest(java.io.DataInputStream in, int clientVersion)
static CreateMulticastTopicRequest	readCreateMulticastTopicRequest(java.io.DataInputStream in, int clientVersion)
static CreateTopicRequest	readCreateTopicRequest(java.io.DataInputStream in, int clientVersion)
static DeleteTopicRequest	readDeleteTopicRequest(java.io.DataInputStream in)
static GetTopicInstrumentMappingRequest	readGetTopicInstrumentMappingRequest(java.io.DataInputStream in)
static GetTopicInstrumentMappingResponse	readGetTopicInstrumentMappingResponse(java.io.DataInputStream in)
static GetTopicMetadataRequest	readGetTopicMetadataRequest(java.io.DataInputStream in)
static GetTopicMetadataResponse	readGetTopicMetadataResponse(java.io.DataInputStream in)
static GetTopicTemporaryInstrumentMappingRequest	readGetTopicTemporaryInstrumentMappingRequest(java.io.DataInputStream in)
static GetTopicTemporaryInstrumentMappingResponse	readGetTopicTemporaryInstrumentMappingResponse(java.io.DataInputStream in)
static ListTopicsResponse	readListTopicsResponse(java.io.DataInputStream in)
static void	writeAddTopicPublisherRequest(java.io.DataOutputStream out, AddTopicPublisherRequest request)
static void	writeAddTopicPublisherResponse(java.io.DataOutputStream out, AddTopicPublisherResponse response, int clientVersion)
static void	writeAddTopicSubscriberRequest(java.io.DataOutputStream out, AddTopicSubscriberRequest request)
static void	writeAddTopicSubscriberResponse(java.io.DataOutputStream out, AddTopicSubscriberResponse response)
static void	writeCreateCustomTopicRequest(java.io.DataOutputStream out, CreateCustomTopicRequest request, int serverProtocolVersion)
static void	writeCreateMulticastTopicRequest(java.io.DataOutputStream out, CreateMulticastTopicRequest request, int serverProtocolVersion)
static void	writeCreateTopicRequest(java.io.DataOutputStream out, CreateTopicRequest request, int serverProtocolVersion)
static void	writeDeleteTopicRequest(java.io.DataOutputStream out, DeleteTopicRequest request)
static void	writeGetTopicInstrumentMappingRequest(java.io.DataOutputStream out, GetTopicInstrumentMappingRequest request)
static void	writeGetTopicInstrumentMappingResponse(java.io.DataOutputStream out, GetTopicInstrumentMappingResponse response)
static void	writeGetTopicMetadataRequest(java.io.DataOutputStream out, GetTopicMetadataRequest request)
static void	writeGetTopicMetadataResponse(java.io.DataOutputStream out, GetTopicMetadataResponse response)
static void	writeGetTopicTemporaryInstrumentMappingRequest(java.io.DataOutputStream out, GetTopicTemporaryInstrumentMappingRequest request)
static void	writeGetTopicTemporaryInstrumentMappingResponse(java.io.DataOutputStream out, GetTopicTemporaryInstrumentMappingResponse response)
static void	writeListTopicsResponse(java.io.DataOutputStream out, ListTopicsResponse response)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

SINGLE_PUBLISHER_TOPIC_SUPPORT_VERSION

public static final int SINGLE_PUBLISHER_TOPIC_SUPPORT_VERSION

See Also:

Constant Field Values

Constructor Detail

TopicProtocol

public TopicProtocol()

Method Detail

writeCreateTopicRequest

public static void writeCreateTopicRequest(java.io.DataOutputStream out,
                                           CreateTopicRequest request,
                                           int serverProtocolVersion)
                                    throws java.io.IOException

Throws:

java.io.IOException

readCreateTopicRequest

public static CreateTopicRequest readCreateTopicRequest(java.io.DataInputStream in,
                                                        int clientVersion)
                                                 throws java.io.IOException

Throws:

java.io.IOException

writeCreateMulticastTopicRequest

public static void writeCreateMulticastTopicRequest(java.io.DataOutputStream out,
                                                    CreateMulticastTopicRequest request,
                                                    int serverProtocolVersion)
                                             throws java.io.IOException

Throws:

java.io.IOException

readCreateMulticastTopicRequest

public static CreateMulticastTopicRequest readCreateMulticastTopicRequest(java.io.DataInputStream in,
                                                                          int clientVersion)
                                                                   throws java.io.IOException

Throws:

java.io.IOException

writeCreateCustomTopicRequest

public static void writeCreateCustomTopicRequest(java.io.DataOutputStream out,
                                                 CreateCustomTopicRequest request,
                                                 int serverProtocolVersion)
                                          throws java.io.IOException

Throws:

java.io.IOException

readCreateCustomTopicRequest

public static CreateCustomTopicRequest readCreateCustomTopicRequest(java.io.DataInputStream in,
                                                                    int clientVersion)
                                                             throws java.io.IOException

Throws:

java.io.IOException

writeDeleteTopicRequest

public static void writeDeleteTopicRequest(java.io.DataOutputStream out,
                                           DeleteTopicRequest request)
                                    throws java.io.IOException

Throws:

java.io.IOException

readDeleteTopicRequest

public static DeleteTopicRequest readDeleteTopicRequest(java.io.DataInputStream in)
                                                 throws java.io.IOException

Throws:

java.io.IOException

writeAddTopicPublisherRequest

public static void writeAddTopicPublisherRequest(java.io.DataOutputStream out,
                                                 AddTopicPublisherRequest request)
                                          throws java.io.IOException

Throws:

java.io.IOException

readAddTopicPublisherRequest

public static AddTopicPublisherRequest readAddTopicPublisherRequest(java.io.DataInputStream in)
                                                             throws java.io.IOException

Throws:

java.io.IOException

writeAddTopicPublisherResponse

public static void writeAddTopicPublisherResponse(java.io.DataOutputStream out,
                                                  AddTopicPublisherResponse response,
                                                  int clientVersion)
                                           throws java.io.IOException

Throws:

java.io.IOException

readAddTopicPublisherResponse

public static AddTopicPublisherResponse readAddTopicPublisherResponse(java.io.DataInputStream in,
                                                                      int serverVersion)
                                                               throws java.io.IOException

Throws:

java.io.IOException

writeAddTopicSubscriberRequest

public static void writeAddTopicSubscriberRequest(java.io.DataOutputStream out,
                                                  AddTopicSubscriberRequest request)
                                           throws java.io.IOException

Throws:

java.io.IOException

readAddTopicSubscriberRequest

public static AddTopicSubscriberRequest readAddTopicSubscriberRequest(java.io.DataInputStream in)
                                                               throws java.io.IOException

Throws:

java.io.IOException

writeAddTopicSubscriberResponse

public static void writeAddTopicSubscriberResponse(java.io.DataOutputStream out,
                                                   AddTopicSubscriberResponse response)
                                            throws java.io.IOException

Throws:

java.io.IOException

readAddTopicSubscriberResponse

public static AddTopicSubscriberResponse readAddTopicSubscriberResponse(java.io.DataInputStream in)
                                                                 throws java.io.IOException

Throws:

java.io.IOException

writeListTopicsResponse

public static void writeListTopicsResponse(java.io.DataOutputStream out,
                                           ListTopicsResponse response)
                                    throws java.io.IOException

Throws:

java.io.IOException

readListTopicsResponse

public static ListTopicsResponse readListTopicsResponse(java.io.DataInputStream in)
                                                 throws java.io.IOException

Throws:

java.io.IOException

writeGetTopicMetadataRequest

public static void writeGetTopicMetadataRequest(java.io.DataOutputStream out,
                                                GetTopicMetadataRequest request)
                                         throws java.io.IOException

Throws:

java.io.IOException

readGetTopicMetadataRequest

public static GetTopicMetadataRequest readGetTopicMetadataRequest(java.io.DataInputStream in)
                                                           throws java.io.IOException

Throws:

java.io.IOException

writeGetTopicMetadataResponse

public static void writeGetTopicMetadataResponse(java.io.DataOutputStream out,
                                                 GetTopicMetadataResponse response)
                                          throws java.io.IOException

Throws:

java.io.IOException

readGetTopicMetadataResponse

public static GetTopicMetadataResponse readGetTopicMetadataResponse(java.io.DataInputStream in)
                                                             throws java.io.IOException

Throws:

java.io.IOException

writeGetTopicInstrumentMappingRequest

public static void writeGetTopicInstrumentMappingRequest(java.io.DataOutputStream out,
                                                         GetTopicInstrumentMappingRequest request)
                                                  throws java.io.IOException

Throws:

java.io.IOException

readGetTopicInstrumentMappingRequest

public static GetTopicInstrumentMappingRequest readGetTopicInstrumentMappingRequest(java.io.DataInputStream in)
                                                                             throws java.io.IOException

Throws:

java.io.IOException

writeGetTopicInstrumentMappingResponse

public static void writeGetTopicInstrumentMappingResponse(java.io.DataOutputStream out,
                                                          GetTopicInstrumentMappingResponse response)
                                                   throws java.io.IOException

Throws:

java.io.IOException

readGetTopicInstrumentMappingResponse

public static GetTopicInstrumentMappingResponse readGetTopicInstrumentMappingResponse(java.io.DataInputStream in)
                                                                               throws java.io.IOException

Throws:

java.io.IOException

writeGetTopicTemporaryInstrumentMappingRequest

public static void writeGetTopicTemporaryInstrumentMappingRequest(java.io.DataOutputStream out,
                                                                  GetTopicTemporaryInstrumentMappingRequest request)
                                                           throws java.io.IOException

Throws:

java.io.IOException

readGetTopicTemporaryInstrumentMappingRequest

public static GetTopicTemporaryInstrumentMappingRequest readGetTopicTemporaryInstrumentMappingRequest(java.io.DataInputStream in)
                                                                                               throws java.io.IOException

Throws:

java.io.IOException

writeGetTopicTemporaryInstrumentMappingResponse

public static void writeGetTopicTemporaryInstrumentMappingResponse(java.io.DataOutputStream out,
                                                                   GetTopicTemporaryInstrumentMappingResponse response)
                                                            throws java.io.IOException

Throws:

java.io.IOException

readGetTopicTemporaryInstrumentMappingResponse

public static GetTopicTemporaryInstrumentMappingResponse readGetTopicTemporaryInstrumentMappingResponse(java.io.DataInputStream in)
                                                                                                 throws java.io.IOException

Throws:

java.io.IOException