Class: Pgbus::Web::Streamer::StreamEventDispatcher::WriteAckMessage

Inherits:

Data

• Object
• Data
• Pgbus::Web::Streamer::StreamEventDispatcher::WriteAckMessage

Defined in:

lib/pgbus/web/streamer/stream_event_dispatcher.rb

Overview

Posted by the OutboundPump (issue #321) after a successful off-thread durable fanout write, carrying the highest msg_id the writer actually committed for the connection. The dispatcher — the sole owner of cursor by accepted_max, so a failed/partial write never advances the cursor past a frame that didn't reach the socket.

Instance Attribute Summary

• #accepted_max ⇒ Object readonly

  Returns the value of attribute accepted_max.

• #connection ⇒ Object readonly

  Returns the value of attribute connection.

Instance Attribute Details

#accepted_max ⇒ Object (readonly)

Returns the value of attribute accepted_max

Returns:

• (Object) —

  the current value of accepted_max

# File 'lib/pgbus/web/streamer/stream_event_dispatcher.rb', line 44

def accepted_max
  @accepted_max
end

#connection ⇒ Object (readonly)

Returns the value of attribute connection

Returns:

• (Object) —

  the current value of connection

# File 'lib/pgbus/web/streamer/stream_event_dispatcher.rb', line 44

def connection
  @connection
end