AMQPConnection_1_0 (Qpid Java Build 6.0.4 API)

java.lang.Object
- org.apache.qpid.server.model.AbstractConfiguredObject<C>
- - org.apache.qpid.server.transport.AbstractAMQPConnection<AMQPConnection_1_0>
  - - org.apache.qpid.server.protocol.v1_0.AMQPConnection_1_0

All Implemented Interfaces:

FrameOutputHandler, ConfiguredObject<AMQPConnection_1_0>, Connection<AMQPConnection_1_0>, AMQPConnection<AMQPConnection_1_0>, ProtocolEngine, Deletable<AMQPConnection_1_0>, TransportActivity
```
public class AMQPConnection_1_0
extends AbstractAMQPConnection<AMQPConnection_1_0>
implements FrameOutputHandler
```

Nested Class Summary
- Nested classes/interfaces inherited from class org.apache.qpid.server.model.AbstractConfiguredObject
  AbstractConfiguredObject.CallableWithArgument<V,A>, AbstractConfiguredObject.ChainedListenableFuture<V>, AbstractConfiguredObject.ChainedSettableFuture<V>, AbstractConfiguredObject.DuplicateIdException, AbstractConfiguredObject.DuplicateNameException

Field Summary

Fields
Modifier and Type Field and Description

static long CLOSE_RESPONSE_TIMEOUT

static org.slf4j.Logger LOGGER
- Fields inherited from class org.apache.qpid.server.model.AbstractConfiguredObject
  SECURED_STRING_VALUE
- Fields inherited from interface org.apache.qpid.server.model.Connection
  CLIENT_ID, CLIENT_VERSION, DEFAULT_MAX_UNCOMMITTED_IN_MEMORY_SIZE, INCOMING, LOCAL_ADDRESS, MAX_UNCOMMITTED_IN_MEMORY_SIZE, PORT, PRINCIPAL, PROPERTIES, REMOTE_ADDRESS, REMOTE_PROCESS_NAME, REMOTE_PROCESS_PID, SESSION_COUNT_LIMIT, STATE, TRANSPORT
- Fields inherited from interface org.apache.qpid.server.model.ConfiguredObject
  CONTEXT, CREATED_BY, CREATED_TIME, DESCRIPTION, DESIRED_STATE, DURABLE, ID, LAST_UPDATED_BY, LAST_UPDATED_TIME, LIFETIME_POLICY, NAME, OVER_SIZED_ATTRIBUTE_ALTERNATIVE_TEXT, TYPE

Fields
Modifier and Type	Field and Description
`static long`	`CLOSE_RESPONSE_TIMEOUT`
`static org.slf4j.Logger`	`LOGGER`

Constructor Summary

Constructors
Constructor and Description
`AMQPConnection_1_0(Broker<?> broker, ServerNetworkConnection network, AmqpPort<?> port, Transport transport, long id, AggregateTicker aggregateTicker, boolean useSASL)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`block()`
`boolean`	`canSend()`
`void`	`clearWork()`
`void`	`close()`
`void`	`closed()`
`void`	`closeSessionAsync(AMQSessionModel<?> session, AMQConstant cause, String message)`
`void`	`encryptedTransport()`
`String`	`getAddress()`
`Principal`	`getAuthorizedPrincipal()`
`protected EventLogger`	`getEventLogger()`
`String`	`getRemoteContainerName()`
`ByteBufferSender`	`getSender()`
`long`	`getSessionCountLimit()`
`List<Session_1_0>`	`getSessionModels()`
`boolean`	`hasSessionWithName(byte[] name)`
`boolean`	`hasWork()`
`void`	`initialiseHeartbeating(long writerDelay, long readerDelay)`
`ByteBuffer`	`initiateNonSasl(List<String> mechanisms)`
`ByteBuffer`	`initiateSasl()`
`boolean`	`isTransportBlockedForWriting()`
`void`	`notifyWork()`
`protected void`	`performDeleteTasks()`
`Iterator<Runnable>`	`processPendingIterator()`
`void`	`readerIdle()`
`void`	`received(QpidByteBuffer msg)`
`void`	`send(AMQFrame amqFrame)`
`void`	`send(AMQFrame amqFrame, ByteBuffer buf)`
`void`	`send(short channel, FrameBody body)`
`void`	`sendConnectionCloseAsync(AMQConstant cause, String message)`
`void`	`setTransportBlockedForWriting(boolean blocked)`
`void`	`setWorkListener(Action<ProtocolEngine> listener)`
`void`	`unblock()`
`void`	`writerIdle()`

Methods inherited from class org.apache.qpid.server.transport.AbstractAMQPConnection
addChildAsync, addDeleteTask, alwaysAllowMessageAssignmentInThisThreadIfItIsIOThread, associateVirtualHost, beforeClose, getAccessControllerContext, getAggregateTicker, getBroker, getBytesIn, getBytesOut, getChildExecutor, getClientId, getClientProduct, getClientVersion, getConnectionId, getDataDeliveryStatistics, getDataReceiptStatistics, getLastIoTime, getLastReadTime, getLastWriteTime, getLocalAddress, getLogSubject, getMessageDeliveryStatistics, getMessageReceiptStatistics, getMessagesIn, getMessagesOut, getNetwork, getPort, getPrincipal, getProtocol, getProtocolEngine, getRemoteAddress, getRemoteAddressString, getRemoteProcessName, getRemoteProcessPid, getRemoteSocketAddress, getSessionCount, getSessions, getSubject, getTransport, getTransportInfo, getUnderlyingConnection, getVirtualHost, getVirtualHostName, isConnectionStopped, isIncoming, isIOThread, isMessageAssignmentSuspended, logConnectionOpen, markTransportClosed, onOpen, popScheduler, pushScheduler, registerMessageDelivered, registerMessageReceived, removeDeleteTask, reserveOutboundMessageSpace, resetStatistics, runAsSubject, sessionAdded, sessionRemoved, setClientId, setClientProduct, setClientVersion, setIOThread, setMessageAssignmentSuspended, setRemoteProcessPid, stopConnection, updateAccessControllerContext, updateLastReadTime, updateLastWriteTime

Methods inherited from class org.apache.qpid.server.model.AbstractConfiguredObject
addChangeListener, applyToChildren, asObjectRecord, attainState, attributeSet, authoriseCreate, authoriseCreateChild, authoriseDelete, authoriseSetAttributes, changeAttribute, changeAttributes, childAdded, childRemoved, closeAsync, closeChildren, create, createAsync, createChild, createChildAsync, decryptSecrets, delete, deleteAsync, deleted, doAfter, doAfter, doAfter, doAfter, doAfter, doAfter, doAfterAlways, doAfterAlways, doCreation, doOnConfigThread, doOpening, doResolution, doSync, doSync, doValidation, findConfiguredObject, forceUpdateAllSecureAttributes, getActualAttributes, getAttainedChildById, getAttainedChildByName, getAttribute, getAttributeNames, getCategoryClass, getChildById, getChildByName, getChildren, getContext, getContextKeys, getContextValue, getContextValue, getCreatedBy, getCreatedTime, getDescription, getDesiredState, getId, getLastOpenedTime, getLastUpdatedBy, getLastUpdatedTime, getLifetimePolicy, getModel, getName, getObjectFactory, getParent, getSecurityManager, getState, getStatistics, getTaskExecutor, getType, getTypeClass, handleExceptionOnOpen, isDurable, managesChildStorage, notifyStateChanged, onClose, onCreate, onExceptionInOpen, onResolve, onValidate, open, openAsync, parentsMap, postResolve, postResolveChildren, registerWithParents, removeChangeListener, rethrowRuntimeExceptionsOnOpen, runTask, setAttribute, setAttributes, setAttributesAsync, setEncrypter, setState, start, startAsync, stop, toString, validateChange, validateOnCreate

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Field Detail
  - LOGGER
```
public static org.slf4j.Logger LOGGER
```
  - CLOSE_RESPONSE_TIMEOUT
```
public static final long CLOSE_RESPONSE_TIMEOUT
```
    See Also:
    
    Constant Field Values
- Constructor Detail
  - AMQPConnection_1_0
```
public AMQPConnection_1_0(Broker<?> broker,
                          ServerNetworkConnection network,
                          AmqpPort<?> port,
                          Transport transport,
                          long id,
                          AggregateTicker aggregateTicker,
                          boolean useSASL)
```
- Method Detail
  - getSender
```
public ByteBufferSender getSender()
```
  - initiateNonSasl
```
public ByteBuffer initiateNonSasl(List<String> mechanisms)
```
  - initiateSasl
```
public ByteBuffer initiateSasl()
```
  - writerIdle
```
public void writerIdle()
```
    Specified by:
    
    writerIdle in interface ProtocolEngine
    
    Specified by:
    
    writerIdle in interface TransportActivity
  - readerIdle
```
public void readerIdle()
```
    Specified by:
    
    readerIdle in interface ProtocolEngine
    
    Specified by:
    
    readerIdle in interface TransportActivity
  - encryptedTransport
```
public void encryptedTransport()
```
    Specified by:
    
    encryptedTransport in interface ProtocolEngine
  - getAddress
```
public String getAddress()
```
  - received
```
public void received(QpidByteBuffer msg)
```
    Specified by:
    
    received in interface ProtocolEngine
  - closed
```
public void closed()
```
    Specified by:
    
    closed in interface ProtocolEngine
  - canSend
```
public boolean canSend()
```
    Specified by:
    
    canSend in interface FrameOutputHandler
  - send
```
public void send(AMQFrame amqFrame)
```
    Specified by:
    
    send in interface FrameOutputHandler
  - send
```
public void send(AMQFrame amqFrame,
                 ByteBuffer buf)
```
    Specified by:
    
    send in interface FrameOutputHandler
  - send
```
public void send(short channel,
                 FrameBody body)
```
  - performDeleteTasks
```
protected void performDeleteTasks()
```
    Overrides:
    
    performDeleteTasks in class AbstractAMQPConnection<AMQPConnection_1_0>
  - close
```
public void close()
```
    Specified by:
    
    close in interface FrameOutputHandler
    
    Specified by:
    
    close in interface ConfiguredObject<AMQPConnection_1_0>
    
    Overrides:
    
    close in class AbstractConfiguredObject<AMQPConnection_1_0>
  - isTransportBlockedForWriting
```
public boolean isTransportBlockedForWriting()
```
    Specified by:
    
    isTransportBlockedForWriting in interface ProtocolEngine
  - setTransportBlockedForWriting
```
public void setTransportBlockedForWriting(boolean blocked)
```
    Specified by:
    
    setTransportBlockedForWriting in interface ProtocolEngine
  - processPendingIterator
```
public Iterator<Runnable> processPendingIterator()
```
    Specified by:
    
    processPendingIterator in interface ProtocolEngine
  - hasWork
```
public boolean hasWork()
```
    Specified by:
    
    hasWork in interface ProtocolEngine
  - notifyWork
```
public void notifyWork()
```
    Specified by:
    
    notifyWork in interface AMQPConnection<AMQPConnection_1_0>
    
    Specified by:
    
    notifyWork in interface ProtocolEngine
  - clearWork
```
public void clearWork()
```
    Specified by:
    
    clearWork in interface ProtocolEngine
  - setWorkListener
```
public void setWorkListener(Action<ProtocolEngine> listener)
```
    Specified by:
    
    setWorkListener in interface ProtocolEngine
  - hasSessionWithName
```
public boolean hasSessionWithName(byte[] name)
```
    Specified by:
    
    hasSessionWithName in interface AMQPConnection<AMQPConnection_1_0>
  - sendConnectionCloseAsync
```
public void sendConnectionCloseAsync(AMQConstant cause,
                                     String message)
```
    Specified by:
    
    sendConnectionCloseAsync in interface AMQPConnection<AMQPConnection_1_0>
  - getAuthorizedPrincipal
```
public Principal getAuthorizedPrincipal()
```
    Specified by:
    
    getAuthorizedPrincipal in interface AMQPConnection<AMQPConnection_1_0>
  - closeSessionAsync
```
public void closeSessionAsync(AMQSessionModel<?> session,
                              AMQConstant cause,
                              String message)
```
    Specified by:
    
    closeSessionAsync in interface AMQPConnection<AMQPConnection_1_0>
  - block
```
public void block()
```
    Specified by:
    
    block in interface AMQPConnection<AMQPConnection_1_0>
  - getRemoteContainerName
```
public String getRemoteContainerName()
```
    Specified by:
    
    getRemoteContainerName in interface AMQPConnection<AMQPConnection_1_0>
  - getSessionModels
```
public List<Session_1_0> getSessionModels()
```
    Specified by:
    
    getSessionModels in interface AMQPConnection<AMQPConnection_1_0>
  - unblock
```
public void unblock()
```
    Specified by:
    
    unblock in interface AMQPConnection<AMQPConnection_1_0>
  - getSessionCountLimit
```
public long getSessionCountLimit()
```
    Specified by:
    
    getSessionCountLimit in interface Connection<AMQPConnection_1_0>
  - getEventLogger
```
protected EventLogger getEventLogger()
```
    Specified by:
    
    getEventLogger in class AbstractAMQPConnection<AMQPConnection_1_0>
  - initialiseHeartbeating
```
public void initialiseHeartbeating(long writerDelay,
                                   long readerDelay)
```
    Overrides:
    
    initialiseHeartbeating in class AbstractAMQPConnection<AMQPConnection_1_0>

Class AMQPConnection_1_0

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.qpid.server.model.AbstractConfiguredObject

Field Summary

Fields inherited from class org.apache.qpid.server.model.AbstractConfiguredObject

Fields inherited from interface org.apache.qpid.server.model.Connection

Fields inherited from interface org.apache.qpid.server.model.ConfiguredObject

Constructor Summary

Method Summary

Methods inherited from class org.apache.qpid.server.transport.AbstractAMQPConnection

Methods inherited from class org.apache.qpid.server.model.AbstractConfiguredObject

Methods inherited from class java.lang.Object

Methods inherited from interface org.apache.qpid.server.model.ConfiguredObject

Field Detail

LOGGER

CLOSE_RESPONSE_TIMEOUT

Constructor Detail

AMQPConnection_1_0

Method Detail

getSender

initiateNonSasl

initiateSasl

writerIdle

readerIdle

encryptedTransport

getAddress

received

closed

canSend

send

send

send

performDeleteTasks

close

isTransportBlockedForWriting

setTransportBlockedForWriting

processPendingIterator

hasWork

notifyWork

clearWork

setWorkListener

hasSessionWithName

sendConnectionCloseAsync

getAuthorizedPrincipal

closeSessionAsync

block

getRemoteContainerName

getSessionModels

unblock

getSessionCountLimit

getEventLogger

initialiseHeartbeating