Show / Hide Table of Contents

    Class TcpTransport

    An implementation of ITransport that uses sockets to communicate with the broker

    Inheritance
    System.Object
    TcpTransport
    SslTransport
    Implements
    ITransport
    Apache.NMS.IStartable
    System.IDisposable
    Apache.NMS.IStoppable
    Inherited Members
    System.Object.Equals(System.Object)
    System.Object.Equals(System.Object, System.Object)
    System.Object.GetHashCode()
    System.Object.GetType()
    System.Object.MemberwiseClone()
    System.Object.ReferenceEquals(System.Object, System.Object)
    System.Object.ToString()
    Namespace: Apache.NMS.ActiveMQ.Transport.Tcp
    Assembly: Apache.NMS.ActiveMQ.dll
    Syntax
    public class TcpTransport : ITransport, IStartable, IDisposable, IStoppable

    Constructors

    | Improve this Doc View Source

    TcpTransport(Uri, Socket, IWireFormat)

    Declaration
    public TcpTransport(Uri uri, Socket socket, IWireFormat wireformat)
    Parameters
    Type Name Description
    System.Uri uri
    System.Net.Sockets.Socket socket
    IWireFormat wireformat

    Fields

    | Improve this Doc View Source

    myLock

    Declaration
    protected readonly object myLock
    Field Value
    Type Description
    System.Object
    | Improve this Doc View Source

    socket

    Declaration
    protected readonly Socket socket
    Field Value
    Type Description
    System.Net.Sockets.Socket

    Properties

    | Improve this Doc View Source

    AsyncTimeout

    Timeout in milliseconds to wait for sending asynchronous messages or commands. Set to -1 for infinite timeout.

    Declaration
    public int AsyncTimeout { get; set; }
    Property Value
    Type Description
    System.Int32
    | Improve this Doc View Source

    Command

    Declaration
    public CommandHandler Command { get; set; }
    Property Value
    Type Description
    CommandHandler
    | Improve this Doc View Source

    Exception

    Declaration
    public ExceptionHandler Exception { get; set; }
    Property Value
    Type Description
    ExceptionHandler
    | Improve this Doc View Source

    Interrupted

    Declaration
    public InterruptedHandler Interrupted { get; set; }
    Property Value
    Type Description
    InterruptedHandler
    | Improve this Doc View Source

    IsConnected

    Declaration
    public bool IsConnected { get; }
    Property Value
    Type Description
    System.Boolean
    | Improve this Doc View Source

    IsDisposed

    Declaration
    public bool IsDisposed { get; }
    Property Value
    Type Description
    System.Boolean
    | Improve this Doc View Source

    IsFaultTolerant

    Declaration
    public bool IsFaultTolerant { get; }
    Property Value
    Type Description
    System.Boolean
    | Improve this Doc View Source

    IsReconnectSupported

    Declaration
    public bool IsReconnectSupported { get; }
    Property Value
    Type Description
    System.Boolean
    | Improve this Doc View Source

    IsStarted

    Property IsStarted

    Declaration
    public bool IsStarted { get; }
    Property Value
    Type Description
    System.Boolean
    | Improve this Doc View Source

    IsUpdateURIsSupported

    Declaration
    public bool IsUpdateURIsSupported { get; }
    Property Value
    Type Description
    System.Boolean
    | Improve this Doc View Source

    ReceiveBufferSize

    Declaration
    public int ReceiveBufferSize { get; set; }
    Property Value
    Type Description
    System.Int32
    | Improve this Doc View Source

    RemoteAddress

    Declaration
    public Uri RemoteAddress { get; }
    Property Value
    Type Description
    System.Uri
    | Improve this Doc View Source

    Resumed

    Declaration
    public ResumedHandler Resumed { get; set; }
    Property Value
    Type Description
    ResumedHandler
    | Improve this Doc View Source

    SendBufferSize

    Declaration
    public int SendBufferSize { get; set; }
    Property Value
    Type Description
    System.Int32
    | Improve this Doc View Source

    TcpNoDelayEnabled

    Declaration
    public bool TcpNoDelayEnabled { get; set; }
    Property Value
    Type Description
    System.Boolean
    | Improve this Doc View Source

    Timeout

    Timeout in milliseconds to wait for sending synchronous messages or commands. Set to -1 for infinite timeout.

    Declaration
    public int Timeout { get; set; }
    Property Value
    Type Description
    System.Int32
    | Improve this Doc View Source

    WireFormat

    Declaration
    public IWireFormat WireFormat { get; set; }
    Property Value
    Type Description
    IWireFormat

    Methods

    | Improve this Doc View Source

    AsyncRequest(Command)

    Declaration
    public FutureResponse AsyncRequest(Command command)
    Parameters
    Type Name Description
    Command command
    Returns
    Type Description
    FutureResponse
    | Improve this Doc View Source

    Close()

    Declaration
    public void Close()
    | Improve this Doc View Source

    CreateSocketStream()

    Declaration
    protected virtual Stream CreateSocketStream()
    Returns
    Type Description
    System.IO.Stream
    | Improve this Doc View Source

    Dispose()

    Declaration
    public void Dispose()
    | Improve this Doc View Source

    Dispose(Boolean)

    Declaration
    protected void Dispose(bool disposing)
    Parameters
    Type Name Description
    System.Boolean disposing
    | Improve this Doc View Source

    Finalize()

    Declaration
    protected void Finalize()
    | Improve this Doc View Source

    Narrow(Type)

    Declaration
    public object Narrow(Type type)
    Parameters
    Type Name Description
    System.Type type
    Returns
    Type Description
    System.Object
    | Improve this Doc View Source

    Oneway(Command)

    Declaration
    public virtual void Oneway(Command command)
    Parameters
    Type Name Description
    Command command
    | Improve this Doc View Source

    ReadLoop()

    Declaration
    public void ReadLoop()
    | Improve this Doc View Source

    Request(Command)

    Declaration
    public Response Request(Command command)
    Parameters
    Type Name Description
    Command command
    Returns
    Type Description
    Response
    | Improve this Doc View Source

    Request(Command, TimeSpan)

    Declaration
    public Response Request(Command command, TimeSpan timeout)
    Parameters
    Type Name Description
    Command command
    System.TimeSpan timeout
    Returns
    Type Description
    Response
    | Improve this Doc View Source

    Start()

    Method Start

    Declaration
    public void Start()
    | Improve this Doc View Source

    Stop()

    Declaration
    public void Stop()
    | Improve this Doc View Source

    UpdateURIs(Boolean, Uri[])

    Declaration
    public void UpdateURIs(bool rebalance, Uri[] updatedURIs)
    Parameters
    Type Name Description
    System.Boolean rebalance
    System.Uri[] updatedURIs

    Implements

    ITransport
    Apache.NMS.IStartable
    System.IDisposable
    Apache.NMS.IStoppable
    • Improve this Doc
    • View Source
    Back to top Copyright � 2005-2019 Apache Software Foundation project
    Generated by DocFX