Object
handle(Client client, byte subscriptionId, long offset, long messageCount, long dataSize)
OffsetSpecification
handle(Client client, byte subscriptionId, boolean active)