diff options
Diffstat (limited to 'java/broker/src/main/java/org/apache/qpid/server/txn/TransactionalContext.java')
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/txn/TransactionalContext.java | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/txn/TransactionalContext.java b/java/broker/src/main/java/org/apache/qpid/server/txn/TransactionalContext.java index 1ec216cc8b..74c7e51e69 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/txn/TransactionalContext.java +++ b/java/broker/src/main/java/org/apache/qpid/server/txn/TransactionalContext.java @@ -12,6 +12,7 @@ import org.apache.qpid.AMQException; import org.apache.qpid.server.ack.UnacknowledgedMessageMap; import org.apache.qpid.server.queue.AMQMessage; import org.apache.qpid.server.queue.AMQQueue; +import org.apache.qpid.server.protocol.AMQProtocolSession; /** * @author Robert Greig (robert.j.greig@jpmorgan.com) @@ -30,4 +31,6 @@ public interface TransactionalContext UnacknowledgedMessageMap unacknowledgedMessageMap) throws AMQException; void messageFullyReceived(boolean persistent) throws AMQException; + + void messageProcessed(AMQProtocolSession protocolSession) throws AMQException; } |