src/main/java/com/io7m/aeron_guide/take4/aeron_messaging/server/AeronMessagingServerDuologue.java
/**
     * Poll the duologue for activity.The handler will pass received message to
     * on_private_message_received()
     *
     * @return
     */
Poll the duologue for activity.The handler will pass received message to
on_private_message_received()

@return
Poll the duologue for activity . The handler will pass received message to on_private_message_received () @return
public int send_enqueued_messages()
            throws IOException {
        this.exec.assertIsExecutorThread();
        if (!private_publication.isConnected() || outgoing_messages_to_private_queue.isEmpty()) {
            return 0;
        }
        String outgoing_message = outgoing_messages_to_private_queue.poll();
        if (send_private_message_to_client(outgoing_message)) {
            return 1;
        } else {
            return 0;
        }
    }
public int send_enqueued_messages ( ) throws IOException { this . exec . assertIsExecutorThread ( ) ; if ( ! private_publication . isConnected ( ) || outgoing_messages_to_private_queue . isEmpty ( ) ) { return 0 ; } String outgoing_message = outgoing_messages_to_private_queue . poll ( ) ; if ( send_private_message_to_client ( outgoing_message ) ) { return 1 ; } else { return 0 ; } }
Poll the duologue for activity.The handler will pass received message to
 on_private_message_received()
Poll the duologue for activity . The handler will pass received message to on_private_message_received ()