Session_1_0 (Apache Qpid AMQP 1-0 Protocol Broker Plug-in 6.1.6 API)

java.lang.Object
- org.apache.qpid.server.protocol.v1_0.Session_1_0

All Implemented Interfaces:

Comparable<AMQSessionModel>, LogSubject, AMQSessionModel<Session_1_0>, Deletable<Session_1_0>
```
public class Session_1_0
extends Object
implements AMQSessionModel<Session_1_0>, LogSubject
```

Constructor Summary

Constructors
Constructor and Description

Session_1_0(AMQPConnection_1_0 connection)

Session_1_0(AMQPConnection_1_0 connection, Begin begin)

Constructors
Constructor and Description
`Session_1_0(AMQPConnection_1_0 connection)`
`Session_1_0(AMQPConnection_1_0 connection, Begin begin)`

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`addConsumerListener(ConsumerListener listener)`
`void`	`addDeleteTask(Action<? super Session_1_0> task)`
`void`	`addTicker(org.apache.qpid.transport.network.Ticker ticker)`
`void`	`block()`
`void`	`block(Queue<?> queue)`
`void`	`close()`
`void`	`close(org.apache.qpid.protocol.AMQConstant cause, String message)`
`int`	`compareTo(AMQSessionModel o)`
`void`	`doTimeoutAction(String reason)`
`void`	`end()`
`void`	`end(End end)`
`void`	`ensureConsumersNoticedStateChange()`
`AMQPConnection<?>`	`getAMQPConnection()`
`boolean`	`getBlocking()`
`int`	`getChannelId()`
`AMQPConnection_1_0`	`getConnection()`
`Object`	`getConnectionReference()`
`int`	`getConsumerCount()`
`Collection<Consumer<?>>`	`getConsumers()`
`UUID`	`getId()`
`LogSubject`	`getLogSubject()`
`Session<?>`	`getModelObject()`
`UnsignedInteger`	`getNextOutgoingId()`
`UnsignedInteger`	`getOutgoingWindowSize()`
`SecurityToken`	`getSecurityToken()`
`SessionState`	`getState()`
`Subject`	`getSubject()`
`long`	`getTransactionStartTime()`
`long`	`getTransactionUpdateTime()`
`Long`	`getTxnCommits()`
`Long`	`getTxnCount()`
`Long`	`getTxnRejects()`
`Long`	`getTxnStart()`
`int`	`getUnacknowledgedMessageCount()`
`boolean`	`hasCreditToSend()`
`boolean`	`isActive()`
`boolean`	`isSyntheticError(Error error)`
`void`	`notifyConsumerTargetCurrentStates()`
`boolean`	`processPending()`
`void`	`receiveAttach(Attach attach)`
`void`	`receiveDetach(Detach detach)`
`void`	`receiveDisposition(Disposition disposition)`
`void`	`receiveEnd(End end)`
`void`	`receiveFlow(Flow flow)`
`void`	`receiveTransfer(Transfer transfer)`
`void`	`remoteLinkCreation(LinkEndpoint endpoint)`
`void`	`removeConsumerListener(ConsumerListener listener)`
`void`	`removeDeleteTask(Action<? super Session_1_0> task)`
`void`	`removeTicker(org.apache.qpid.transport.network.Ticker ticker)`
`void`	`sendAttach(Attach attach)`
`void`	`sendDetach(Detach detach)`
`void`	`sendFlow()`
`void`	`sendFlow(Flow flow)`
`void`	`sendFlowConditional()`
`void`	`sendTransfer(Transfer xfr, SendingLinkEndpoint endpoint, boolean newDelivery)`
`void`	`setModelObject(Session<?> session)`
`void`	`setNextIncomingId(UnsignedInteger nextIncomingId)`
`void`	`setOutgoingSessionCredit(UnsignedInteger outgoingSessionCredit)`
`void`	`setReceivingChannel(short receivingChannel)`
`void`	`setSendingChannel(short sendingChannel)`
`String`	`toLogString()`
`String`	`toString()`
`void`	`transportStateChanged()`
`void`	`unblock()`
`void`	`unblock(Queue<?> queue)`
`void`	`updateDisposition(Role role, UnsignedInteger first, UnsignedInteger last, DeliveryState state, boolean settled)`

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

- Constructor Detail
  - Session_1_0
```
public Session_1_0(AMQPConnection_1_0 connection)
```
  - Session_1_0
```
public Session_1_0(AMQPConnection_1_0 connection,
           Begin begin)
```
- Method Detail
  - setReceivingChannel
```
public void setReceivingChannel(short receivingChannel)
```
  - sendDetach
```
public void sendDetach(Detach detach)
```
  - receiveAttach
```
public void receiveAttach(Attach attach)
```
  - updateDisposition
```
public void updateDisposition(Role role,
                     UnsignedInteger first,
                     UnsignedInteger last,
                     DeliveryState state,
                     boolean settled)
```
  - hasCreditToSend
```
public boolean hasCreditToSend()
```
  - end
```
public void end()
```
  - sendTransfer
```
public void sendTransfer(Transfer xfr,
                SendingLinkEndpoint endpoint,
                boolean newDelivery)
```
  - isActive
```
public boolean isActive()
```
  - receiveEnd
```
public void receiveEnd(End end)
```
  - getNextOutgoingId
```
public UnsignedInteger getNextOutgoingId()
```
  - sendFlowConditional
```
public void sendFlowConditional()
```
  - getOutgoingWindowSize
```
public UnsignedInteger getOutgoingWindowSize()
```
  - receiveFlow
```
public void receiveFlow(Flow flow)
```
  - setNextIncomingId
```
public void setNextIncomingId(UnsignedInteger nextIncomingId)
```
  - receiveDisposition
```
public void receiveDisposition(Disposition disposition)
```
  - getState
```
public SessionState getState()
```
  - sendFlow
```
public void sendFlow()
```
  - setSendingChannel
```
public void setSendingChannel(short sendingChannel)
```
  - sendFlow
```
public void sendFlow(Flow flow)
```
  - setOutgoingSessionCredit
```
public void setOutgoingSessionCredit(UnsignedInteger outgoingSessionCredit)
```
  - receiveDetach
```
public void receiveDetach(Detach detach)
```
  - sendAttach
```
public void sendAttach(Attach attach)
```
  - isSyntheticError
```
public boolean isSyntheticError(Error error)
```
  - end
```
public void end(End end)
```
  - receiveTransfer
```
public void receiveTransfer(Transfer transfer)
```
  - remoteLinkCreation
```
public void remoteLinkCreation(LinkEndpoint endpoint)
```
  - getId
```
public UUID getId()
```
    Specified by:
    
    getId in interface AMQSessionModel<Session_1_0>
  - getAMQPConnection
```
public AMQPConnection<?> getAMQPConnection()
```
    Specified by:
    
    getAMQPConnection in interface AMQSessionModel<Session_1_0>
  - close
```
public void close()
```
    Specified by:
    
    close in interface AMQSessionModel<Session_1_0>
  - close
```
public void close(org.apache.qpid.protocol.AMQConstant cause,
         String message)
```
    Specified by:
    
    close in interface AMQSessionModel<Session_1_0>
  - transportStateChanged
```
public void transportStateChanged()
```
    Specified by:
    
    transportStateChanged in interface AMQSessionModel<Session_1_0>
  - getLogSubject
```
public LogSubject getLogSubject()
```
    Specified by:
    
    getLogSubject in interface AMQSessionModel<Session_1_0>
  - block
```
public void block(Queue<?> queue)
```
    Specified by:
    
    block in interface AMQSessionModel<Session_1_0>
  - unblock
```
public void unblock(Queue<?> queue)
```
    Specified by:
    
    unblock in interface AMQSessionModel<Session_1_0>
  - block
```
public void block()
```
    Specified by:
    
    block in interface AMQSessionModel<Session_1_0>
  - unblock
```
public void unblock()
```
    Specified by:
    
    unblock in interface AMQSessionModel<Session_1_0>
  - getBlocking
```
public boolean getBlocking()
```
    Specified by:
    
    getBlocking in interface AMQSessionModel<Session_1_0>
  - getConnectionReference
```
public Object getConnectionReference()
```
    Specified by:
    
    getConnectionReference in interface AMQSessionModel<Session_1_0>
  - getUnacknowledgedMessageCount
```
public int getUnacknowledgedMessageCount()
```
    Specified by:
    
    getUnacknowledgedMessageCount in interface AMQSessionModel<Session_1_0>
  - getTxnCount
```
public Long getTxnCount()
```
    Specified by:
    
    getTxnCount in interface AMQSessionModel<Session_1_0>
  - getTxnStart
```
public Long getTxnStart()
```
    Specified by:
    
    getTxnStart in interface AMQSessionModel<Session_1_0>
  - getTxnCommits
```
public Long getTxnCommits()
```
    Specified by:
    
    getTxnCommits in interface AMQSessionModel<Session_1_0>
  - getTxnRejects
```
public Long getTxnRejects()
```
    Specified by:
    
    getTxnRejects in interface AMQSessionModel<Session_1_0>
  - getChannelId
```
public int getChannelId()
```
    Specified by:
    
    getChannelId in interface AMQSessionModel<Session_1_0>
  - getConsumerCount
```
public int getConsumerCount()
```
    Specified by:
    
    getConsumerCount in interface AMQSessionModel<Session_1_0>
  - toLogString
```
public String toLogString()
```
    Specified by:
    
    toLogString in interface LogSubject
  - compareTo
```
public int compareTo(AMQSessionModel o)
```
    Specified by:
    
    compareTo in interface Comparable<AMQSessionModel>
  - getConnection
```
public AMQPConnection_1_0 getConnection()
```
  - addDeleteTask
```
public void addDeleteTask(Action<? super Session_1_0> task)
```
    Specified by:
    
    addDeleteTask in interface Deletable<Session_1_0>
  - removeDeleteTask
```
public void removeDeleteTask(Action<? super Session_1_0> task)
```
    Specified by:
    
    removeDeleteTask in interface Deletable<Session_1_0>
  - getSubject
```
public Subject getSubject()
```
  - getSecurityToken
```
public SecurityToken getSecurityToken()
```
  - getConsumers
```
public Collection<Consumer<?>> getConsumers()
```
    Specified by:
    
    getConsumers in interface AMQSessionModel<Session_1_0>
  - addConsumerListener
```
public void addConsumerListener(ConsumerListener listener)
```
    Specified by:
    
    addConsumerListener in interface AMQSessionModel<Session_1_0>
  - removeConsumerListener
```
public void removeConsumerListener(ConsumerListener listener)
```
    Specified by:
    
    removeConsumerListener in interface AMQSessionModel<Session_1_0>
  - setModelObject
```
public void setModelObject(Session<?> session)
```
    Specified by:
    
    setModelObject in interface AMQSessionModel<Session_1_0>
  - getModelObject
```
public Session<?> getModelObject()
```
    Specified by:
    
    getModelObject in interface AMQSessionModel<Session_1_0>
  - getTransactionStartTime
```
public long getTransactionStartTime()
```
    Specified by:
    
    getTransactionStartTime in interface AMQSessionModel<Session_1_0>
  - getTransactionUpdateTime
```
public long getTransactionUpdateTime()
```
    Specified by:
    
    getTransactionUpdateTime in interface AMQSessionModel<Session_1_0>
  - processPending
```
public boolean processPending()
```
    Specified by:
    
    processPending in interface AMQSessionModel<Session_1_0>
  - addTicker
```
public void addTicker(org.apache.qpid.transport.network.Ticker ticker)
```
    Specified by:
    
    addTicker in interface AMQSessionModel<Session_1_0>
  - removeTicker
```
public void removeTicker(org.apache.qpid.transport.network.Ticker ticker)
```
    Specified by:
    
    removeTicker in interface AMQSessionModel<Session_1_0>
  - notifyConsumerTargetCurrentStates
```
public void notifyConsumerTargetCurrentStates()
```
    Specified by:
    
    notifyConsumerTargetCurrentStates in interface AMQSessionModel<Session_1_0>
  - ensureConsumersNoticedStateChange
```
public void ensureConsumersNoticedStateChange()
```
    Specified by:
    
    ensureConsumersNoticedStateChange in interface AMQSessionModel<Session_1_0>
  - doTimeoutAction
```
public void doTimeoutAction(String reason)
```
    Specified by:
    
    doTimeoutAction in interface AMQSessionModel<Session_1_0>
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object

Class Session_1_0

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

Session_1_0

Session_1_0

Method Detail

setReceivingChannel

sendDetach

receiveAttach

updateDisposition

hasCreditToSend

end

sendTransfer

isActive

receiveEnd

getNextOutgoingId

sendFlowConditional

getOutgoingWindowSize

receiveFlow

setNextIncomingId

receiveDisposition

getState

sendFlow

setSendingChannel

sendFlow

setOutgoingSessionCredit

receiveDetach

sendAttach

isSyntheticError

end

receiveTransfer

remoteLinkCreation

getId

getAMQPConnection

close

close

transportStateChanged

getLogSubject

block

unblock

block

unblock

getBlocking

getConnectionReference

getUnacknowledgedMessageCount

getTxnCount

getTxnStart

getTxnCommits

getTxnRejects

getChannelId

getConsumerCount

toLogString

compareTo

getConnection

addDeleteTask

removeDeleteTask

getSubject

getSecurityToken

getConsumers

addConsumerListener

removeConsumerListener

setModelObject

getModelObject

getTransactionStartTime

getTransactionUpdateTime

processPending

addTicker

removeTicker

notifyConsumerTargetCurrentStates

ensureConsumersNoticedStateChange

doTimeoutAction

toString