1 18 package org.apache.activemq.command; 19 20 import org.apache.activemq.state.CommandVisitor; 21 22 23 28 public class ConnectionError extends BaseCommand { 29 30 public static final byte DATA_STRUCTURE_TYPE=CommandTypes.CONNECTION_ERROR; 31 32 protected ConnectionId connectionId; 33 Throwable exception; 34 35 public byte getDataStructureType() { 36 return DATA_STRUCTURE_TYPE; 37 } 38 39 public Response visit(CommandVisitor visitor) throws Exception { 40 return visitor.processConnectionError(this); 41 } 42 43 46 public Throwable getException() { 47 return exception; 48 } 49 50 public void setException(Throwable exception) { 51 this.exception = exception; 52 } 53 54 57 public ConnectionId getConnectionId() { 58 return connectionId; 59 } 60 public void setConnectionId(ConnectionId connectionId) { 61 this.connectionId = connectionId; 62 } 63 64 } 65 | Popular Tags |