org.apache.qpid.oldtopic
Class Publisher

java.lang.Object
  extended by org.apache.qpid.oldtopic.Publisher
All Implemented Interfaces:
MessageListener

public class Publisher
extends Object
implements MessageListener


Constructor Summary
Publisher(Connection connection, int size, int ackMode, boolean persistent)
           
 
Method Summary
(package private) static long avg(long[] times, long min, long max)
           
static void main(String[] argv)
           
(package private) static long max(long[] times)
           
(package private) static long min(long[] times)
           
 void onMessage(Message message)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Publisher

Publisher(Connection connection,
          int size,
          int ackMode,
          boolean persistent)
    throws Exception
Throws:
Exception
Method Detail

onMessage

public void onMessage(Message message)
Specified by:
onMessage in interface MessageListener

min

static long min(long[] times)

max

static long max(long[] times)

avg

static long avg(long[] times,
                long min,
                long max)

main

public static void main(String[] argv)
                 throws Exception
Throws:
Exception


Licensed to the Apache Software Foundation