Module: MessageStore::Postgres::Get::SQLCommand

Defined in:
lib/message_store/postgres/get.rb

Instance Method Summary collapse

Instance Method Details

#sql_command(stream_name, position, batch_size, condition) ⇒ Object 



92
93
94
95
 
# File 'lib/message_store/postgres/get.rb', line 92

def sql_command(stream_name, position, batch_size, condition)
  parameters = '$1::varchar, $2::bigint, $3::bigint, $4::varchar'
  command_text(parameters)
end