code: /*
   * (c) 2005-2017  Copyright, Real-Time Innovations, Inc. All rights reserved.
   * Subject to Eclipse Public License v1.0; see LICENSE.md for details.
   */
  
  package com.rti.perftest;
  
  import java.util.concurrent.TimeUnit;
  
  // ===========================================================================
  
  /**
   * Send messages.
   */
  public interface IMessagingWriter {
      public void waitForReaders(int numReaders);
  
      public boolean send(TestMessage message, boolean isCftWildCardKey);
      public boolean waitForPingResponse();
      public boolean waitForPingResponse(long timeout, TimeUnit unit);
      public boolean notifyPingResponse();
      public long getPulledSampleCount();
      public void waitForAck(int sec, int nsec);
      public void flush();
  
  }
  
  // ===========================================================================
  
  