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