1 18 package org.apache.activemq.transport; 19 20 import java.util.Queue ; 21 import java.util.concurrent.ConcurrentLinkedQueue ; 22 23 24 import java.io.IOException ; 25 26 30 public class StubTransportListener implements TransportListener { 31 32 private Queue commands = new ConcurrentLinkedQueue (); 33 private Queue exceptions = new ConcurrentLinkedQueue (); 34 35 public Queue getCommands() { 36 return commands; 37 } 38 39 public Queue getExceptions() { 40 return exceptions; 41 } 42 43 public void onCommand(Object command) { 44 commands.add(command); 45 } 46 47 public void onException(IOException error) { 48 exceptions.add(error); 49 } 50 51 public void transportInterupted() { 52 } 53 54 public void transportResumed() { 55 } 56 57 } 58 | Popular Tags |