| Methods Summary |
|---|
| public void | down(org.jgroups.Event event)
if( log.isTraceEnabled() )
{
log.trace("down, event="+event);
if( event.getType() == Event.MSG )
{
Message msg = (Message) event.getArg();
log.trace("down, MsgHeader: "+printEventMsg(msg));
}
}
// Pass down the protocol stack
passDown(event);
|
| public java.lang.String | getName()
return name;
|
| public java.lang.String | printEventMsg(org.jgroups.Message msg)
StringBuffer sb = new StringBuffer();
Map.Entry entry;
Map headers = msg.getHeaders();
if (headers != null)
{
Iterator iter = headers.entrySet().iterator();
while( iter.hasNext() )
{
entry = (Map.Entry) iter.next();
Object key = entry.getKey();
Object value = entry.getValue();
sb.append(key);
sb.append(", value(");
sb.append(value.getClass());
sb.append("): ");
sb.append(value.toString());
sb.append("\n");
}
}
return sb.toString();
|
| public boolean | setProperties(java.util.Properties props)
super.setProperties(props);
name = props.getProperty("name", name);
log = Logger.getLogger("org.jboss.jgroups."+name);
return true;
|
| public void | up(org.jgroups.Event event)
if( log.isTraceEnabled() )
{
log.trace("up, event="+event);
if( event.getType() == Event.MSG )
{
Message msg = (Message) event.getArg();
msg.getHeaders();
log.trace("up, MsgHeader: "+printEventMsg(msg));
}
}
// Pass up the protocol stack
passUp(event);
|
