Author: alessio.soldano(a)jboss.com Date: 2007-12-12 11:41:32 -0500 (Wed, 12 Dec 2007) New Revision: 5275 Modified: spi/branches/asoldano/trunk/src/main/java/org/jboss/wsf/spi/deployment/Endpoint.java spi/branches/asoldano/trunk/src/main/java/org/jboss/wsf/spi/management/recording/Record.java spi/branches/asoldano/trunk/src/main/java/org/jboss/wsf/spi/management/recording/RecordGroupAssociation.java spi/branches/asoldano/trunk/src/main/java/org/jboss/wsf/spi/management/recording/RecordProcessor.java Log: Endpoint interface update and minor changes Modified: spi/branches/asoldano/trunk/src/main/java/org/jboss/wsf/spi/deployment/Endpoint.java =================================================================== --- spi/branches/asoldano/trunk/src/main/java/org/jboss/wsf/spi/deployment/Endpoint.java 2007-12-12 16:25:28 UTC (rev 5274) +++ spi/branches/asoldano/trunk/src/main/java/org/jboss/wsf/spi/deployment/Endpoint.java 2007-12-12 16:41:32 UTC (rev 5275) @@ -124,9 +124,5 @@ List<RecordProcessor> getRecordProcessors(); void setRecordProcessors(List<RecordProcessor> recordProcessors); - boolean isRecording(); - - void setRecording(boolean value); - void processRecord(Record record); } Modified: spi/branches/asoldano/trunk/src/main/java/org/jboss/wsf/spi/management/recording/Record.java =================================================================== --- spi/branches/asoldano/trunk/src/main/java/org/jboss/wsf/spi/management/recording/Record.java 2007-12-12 16:25:28 UTC (rev 5274) +++ spi/branches/asoldano/trunk/src/main/java/org/jboss/wsf/spi/management/recording/Record.java 2007-12-12 16:41:32 UTC (rev 5275) @@ -38,9 +38,9 @@ { public enum MessageType {INBOUND, OUTBOUND}; - public Long getGroupID(); + public String getGroupID(); - public void setGroupID(Long groupID); + public void setGroupID(String groupID); public Date getDate(); Modified: spi/branches/asoldano/trunk/src/main/java/org/jboss/wsf/spi/management/recording/RecordGroupAssociation.java =================================================================== --- spi/branches/asoldano/trunk/src/main/java/org/jboss/wsf/spi/management/recording/RecordGroupAssociation.java 2007-12-12 16:25:28 UTC (rev 5274) +++ spi/branches/asoldano/trunk/src/main/java/org/jboss/wsf/spi/management/recording/RecordGroupAssociation.java 2007-12-12 16:41:32 UTC (rev 5275) @@ -34,28 +34,28 @@ */ public class RecordGroupAssociation { - private static ThreadLocal<Stack<Long>> groupIDAssoc = new ThreadLocal<Stack<Long>>(); + private static ThreadLocal<Stack<String>> groupIDAssoc = new ThreadLocal<Stack<String>>(); // provide logging private static Logger log = Logger.getLogger(RecordGroupAssociation.class); - public static void pushGroupID(Long groupID) + public static void pushGroupID(String groupID) { if(log.isDebugEnabled()) log.debug("pushGroupID: " + groupID + " (Thread " +Thread.currentThread().getName()+ ")"); - Stack<Long> stack = groupIDAssoc.get(); + Stack<String> stack = groupIDAssoc.get(); if (stack == null) { - stack = new Stack<Long>(); + stack = new Stack<String>(); groupIDAssoc.set(stack); } stack.push(groupID); } - public static Long peekGroupID() + public static String peekGroupID() { - Long groupID = null; - Stack<Long> stack = groupIDAssoc.get(); + String groupID = null; + Stack<String> stack = groupIDAssoc.get(); if (stack != null && stack.isEmpty() == false) { groupID = stack.peek(); @@ -64,10 +64,10 @@ return groupID; } - public static Long popGroupID() + public static String popGroupID() { - Long groupID = null; - Stack<Long> stack = groupIDAssoc.get(); + String groupID = null; + Stack<String> stack = groupIDAssoc.get(); if (stack != null && stack.isEmpty() == false) { groupID = stack.pop(); Modified: spi/branches/asoldano/trunk/src/main/java/org/jboss/wsf/spi/management/recording/RecordProcessor.java =================================================================== --- spi/branches/asoldano/trunk/src/main/java/org/jboss/wsf/spi/management/recording/RecordProcessor.java 2007-12-12 16:25:28 UTC (rev 5274) +++ spi/branches/asoldano/trunk/src/main/java/org/jboss/wsf/spi/management/recording/RecordProcessor.java 2007-12-12 16:41:32 UTC (rev 5275) @@ -26,37 +26,56 @@ import java.util.List; /** + * Processes a record. A RecordProcessor may have filters to allow processing + * of records matching given criteria. It also gives users fine management of + * record's attributes to processed. * * @author alessio.soldano(a)jboss.com * @since 8-Dec-2007 */ public interface RecordProcessor { - /** - * To be used to have this processor process the specified record - * - * @param record - */ + public String getName(); + + public void setName(String epName); + + public boolean isRecording(); + + public void setRecording(boolean value); + public void processRecord(Record record); - - /** Filters: a record is processed only if it matches all the processor's filters **/ + public List<RecordFilter> getFilters(); + public void addFilter(RecordFilter filter); + public void setFilters(List<RecordFilter> filters); - - /** Fine grained management of records' field to be processed **/ + public boolean isProcessSourceHost(); + public void setProcessSourceHost(boolean value); + public boolean isProcessDestinationHost(); + public void setProcessDestinationHost(boolean value); + public boolean isProcessMessageType(); + public void setProcessMessageType(boolean value); + public boolean isProcessMessage(); + public void setProcessMessage(boolean value); + public boolean isProcessHeaders(); + public void setProcessHeaders(boolean value); + public boolean isProcessOperation(); + public void setProcessOperation(boolean value); + public boolean isProcessDate(); + public void setProcessDate(boolean value); }