OW2 Consortium odis/

Compare Revisions

Ignore whitespace Rev 149 → Rev 150

/trunk/Odis/OdisCore/standalone/src/main/java/org/ow2/odis/connection/memory/MemoryOut.java
41,6 → 41,10
/** logger of this class. */
static final Logger LOGGER = Monolog.initialize().getLogger(
MemoryOut.class.getName());
// use log4j temporally
private org.apache.log4j.Logger jLogger = org.apache.log4j.Logger
.getLogger(this.getClass().getName());
 
/** reference memory instance witch contain objects for the memoryOut. */
private final Memory memory;
91,6 → 95,10
return false;
}
}
if ( jLogger.isDebugEnabled() ) {
jLogger.debug("send " + memory.getAttribute().getName() + " msg="+memory.getAttribute().getNumberMessage()
+" sz="+memory.getAttribute().getSizeByte()+" add message : " + new String(pMsg));
}
attribute.incSizeByte(pMsg.length);
Byte[] bytes = new Byte[pMsg.length];
for (int i = 0; i < pMsg.length; i++) {
/trunk/Odis/OdisCore/standalone/src/main/java/org/ow2/odis/connection/memory/Memory.java
146,6 → 146,10
errMsg.append(EOL);
errMsg.append("\t->the max object size has been set to ");
errMsg.append(attribute.getSizeObjectMax());
errMsg.append("\t the free memory are ");
errMsg.append(attribute.getSizeByte());
errMsg.append("\t size=");
errMsg.append(length);
errMsg.append(EOL);
LOGGER.log(BasicLevel.ERROR, errMsg.toString());
}
/trunk/Odis/OdisCore/standalone/src/main/java/org/ow2/odis/model/MemoryConnectionAttribute.java
21,6 → 21,10
/** The state. */
private int state = 0;
 
// use log4j temporally
private org.apache.log4j.Logger jLogger = org.apache.log4j.Logger
.getLogger(this.getClass());
/**
* Max size message present into memory be careful a message can contain more than one object By defaut the the limit is set to 10000.
*/
50,6 → 54,9
*/
public void incNumberMessage(int value) {
numberMessage += value;
if (jLogger.isDebugEnabled()) {
jLogger.debug("incNumberMessage "+ getName() + ": value" + value+"/" + numberMessage);
}
}
 
/** The size byte. */
59,8 → 66,11
* Inc size byte.
* @param value the value
*/
public void incSizeByte(long value) {
public void incSizeByte(long value) {
sizeByte += value;
if (jLogger.isDebugEnabled()) {
jLogger.debug("incSizeByte "+ getName() + ": value" + value+"/" + numberMessage);
}
}
 
/**