Hi Stanley,
I disabled the cache and did more analysis of the actual timing of the
events, and it appears that the problem is that the bulk load CALL
SYSCS_UTIL.SYSCS_IMPORT_DATA (?,?,?,?,?,?,?,?,?) is not entirely
finishing before I try to query the table it is populating. I would
expect to get a locking exception, or something of that nature, but the
SQL error code that gets returned is either XSCB1 or XSCH1, both of
which come with the message "container <containerName> not found". I
think you're right that it's a Windows caching or heap issue. I am
getting around the problem by trapping for those two error codes,
putting my thread to sleep for awhile, then retrying. It seems to work
fine that way.
An improvement I would suggest is having SYSCS_UTIL.SYSCS_IMPORT_DATA
indicate when it is done loading. As it stands now, the thread I have
running it finishes before the utility finishes, and I have no elegant
way of knowing when the load is done, other than trying to use the table
and trapping for errors, as stated above.
Thanks for your help!
Patty
-----Original Message-----
From: Stanley Bradbury [mailto:[EMAIL PROTECTED]
Sent: Thursday, May 10, 2007 3:18 PM
To: Derby Discussion
Subject: Re: SQL Exception: Container xxx not found
Hi Patty -
I fear this will be a hard one to solve without a reproducible test
case. Before going that route (I assume it will be difficult to provide
a test case) I suggest seeing if this might be system related.
The oddest thing is that the Exception is not in the derby.log along
with the SQLState and stack trace. Missing data (be it exceptions
information or data containers) could be caused by in-memory problems or
possibly I/O caching. Windows write caching is enabled by default and
can cause problems in I/O intensive applications. Please disable this
and see if the problem persists. This can be disabled on XP from the
disk drive/properties/hardware tab/policy tab - more information can be
found, along with a warning, at: http://support.microsoft.com/kb/259716
If the problem still happens would you run your tests using a different
JVM and/or machine to see if this corrects or effects the problem. If
none of these actions resolve the problem then please post the problem
to the derby-dev for additional ideas.
Parker, Patricia (LNG-CON) wrote:
Hi Stanley,
Thanks for your reply.
I am running Derby 10.2.2 in embedded mode on Windows XP platform in
Eclipse. I have attached both the derby.log file and a snapshot of my
Eclipse console, since the actual SQL error shows up there on line
231.
The corresponding messages in derby.log occur around line 185, when
the
rollback starts to happen.
The only mention I have seen of a similar problem in Derby was in the
mail archives here...
<http://mail-archives.apache.org/mod_mbox/db-derby-user/200702.mbox/%3C4
[EMAIL PROTECTED]>
The response to the above mail seemed to imply that Derby may lose
track
of tables, so I have been trying different timings of when I define my
tables in relation to when I do the inserts.
Here is more detail on my process. I am running a "graph" process,
where a node process runs on its own thread and bulk loads a bunch of
data from a flat file into a table that it defines on-the-fly using
some
XML that describes the data in the flat file. After the node process
thread completes, a connector thread runs that applies a filter to all
the data that was just bulk loaded and inserts the filtered data into
another brand new, defined on-the-fly table. This is done by
performing
an INSERT INTO <new connector table> SELECT * FROM <table created for
node> WHERE <some filter statement>. Since this is a graph process,
many node threads may be processing at once, and many connector
threads
may also be processing concurrently. I sometimes have noticed some
deadlocking between connectors, but it seems to recover and move on
ok.
My problem happens whether or not a deadlock message occurs.
My bulk loads have been working fine in the nodes, but I believe the
problem may occur when my program goes to access the bulk loaded data
to
use as data to do the inserts into my new tables in the connectors.
Right now, I define my tables right before loading/inserting into
them.
I have tried defining all my tables up front before running the bulk
loads and inserts. I have also tried sharing instances of the
DriverManager, but that did not seem to help. I now get a new
DriverManager each time I do a bulk load or insert, as the log will
show.
I am currently using the isolation TRANSACTION_READ_COMMITTED, but I
have had the same issue with TRANSACTION_SERIALIZABLE.
Thanks again for your help.
Patty
Below are my methods for bulk load and insert, and for getting a
connection:
Here is my method for doing the bulk load:
public void importData(String tableName, List<FieldType>
columnList,
List<String> columnIndexList, String inputFile,
String columnDelimiter, String charDelimiter, boolean
replace)
{
StringBuffer sb = new StringBuffer();
for (FieldType field : columnList)
{
sb.append(field.getName().toUpperCase());
sb.append(",");
}
sb.deleteCharAt(sb.length() - 1);
String insertColumns = sb.toString();
log.debug("Supposed to bulk load these columns: " +
insertColumns);
String columnIndexes = null;
Connection conn = getConnection();
// convert the boolean 'replace' flag to an integer;
int intReplace = replace ? 1 : 0;
PreparedStatement ps = null;
try
{
ps = conn
.prepareStatement("CALL SYSCS_UTIL.SYSCS_IMPORT_DATA
(?,?,?,?,?,?,?,?,?)");
ps.setString(1, null); // schema name
ps.setString(2, tableName.toUpperCase()); // table name
log.debug("tableName: " + tableName.toUpperCase());
ps.setString(3, insertColumns.toUpperCase());
log.debug("insertColumn: " + insertColumns.toUpperCase());
ps.setString(4, columnIndexes);
log.debug("columnIndexes: " + columnIndexes);
ps.setString(5, inputFile); // input file
log.debug("inputFile: " + inputFile);
ps.setString(6, columnDelimiter); // column delimiter
log.debug("columnDelimiter: " + columnDelimiter);
ps.setString(7, charDelimiter); // character delimiter
log.debug("charDelimiter: " + charDelimiter);
ps.setString(8, null); // code set
ps.setInt(9, intReplace); // if true, empty the table before
log.debug("intReplace: " + intReplace);
// loading. Otherwise, add the data to
// what is already there.
ps.execute();
} catch (Throwable e)
{
log.debug("exception thrown:");
if (e instanceof SQLException)
{
printSQLError((SQLException) e);
}
else
{
e.printStackTrace();
}
} finally
{
try
{
ps.close();
conn.close();
} catch (Throwable e)
{
log.debug("exception thrown:");
if (e instanceof SQLException)
{
printSQLError((SQLException) e);
}
else
{
e.printStackTrace();
}
}
try
{
while (!conn.isClosed())
{
wait(100L);
}
}
catch (SQLException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
catch (InterruptedException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
Here is my method for doing inserts:
public void insertToTable(String tableName, String
selectStatement)
{
Connection conn = getConnection();
Statement s = null;
String insertStatement = ("INSERT INTO " + tableName + " " +
selectStatement);
log.debug("Insert statement: " + insertStatement);
try
{
s = conn.createStatement();
s.execute(insertStatement);
}
catch (Throwable e)
{
log.debug("exception thrown:");
if (e instanceof SQLException)
{
printSQLError((SQLException) e);
}
else
{
e.printStackTrace();
}
}
finally
{
/*
* We end the transaction and the connection.
*/
try
{
s.close();
//conn.commit();
conn.close();
log.debug("closed connection");
}
catch (Throwable e)
{
log.debug("exception thrown:");
if (e instanceof SQLException)
{
printSQLError((SQLException) e);
}
else
{
e.printStackTrace();
}
}
//Make sure connection is closed before going on
try
{
while (!conn.isClosed())
{
wait(100L);
}
}
catch (Throwable e)
{
log.debug("exception thrown:");
if (e instanceof SQLException)
{
printSQLError((SQLException) e);
}
else
{
e.printStackTrace();
}
}
}
}
Method for getting connection...
private static Connection getConnection()
{
System.out
.println("DerbyDBManager starting in " + framework + "
mode.");
Connection conn = null;
try
{
Properties props = new Properties();
props.put("user", username);
props.put("password", "mine");
/*
* The connection specifies create=true to cause the
database to
* be created. To remove the database, remove the
directory
* derbyDB and its contents. The directory derbyDB
will
be
* created under the directory that the system
property
* derby.system.home points to, or the current
directory
if
* derby.system.home is not set.
*/
conn =
DriverManager.getConnection("jdbc:derby:C:/Derby881;create=true",
props);
log.debug("Created connection");
conn.setAutoCommit(true);
conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
}
catch (Throwable e)
{
log.debug("exception thrown:");
if (e instanceof SQLException)
{
printSQLError((SQLException) e);
}
else
{
e.printStackTrace();
}
}
return conn;
}
-----Original Message-----
From: Stanley Bradbury [mailto:[EMAIL PROTECTED]
Sent: Wednesday, May 09, 2007 7:59 PM
To: Derby Discussion
Subject: Re: SQL Exception: Container xxx not found
Parker, Patricia (LNG-CON) wrote:
Hi,
I am developing an application that does bulk loading and inserting
into tables that are created on-the-fly. I create four tables and
bulk-load data into them. Then I run a process that creates four
tables and selectively inserts data from the bulk-loaded tables into
the newly created tables. The bulk loads seem to go fine, but during
the insert process, I am randomly getting the error "SQL Exception:
Container xxx not found". The error does not happen on the same table
every time, and some times everything runs fine. I am only writing at
most eight records to a table, so I have not begun to put a load on
the process yet. Can you provide some guidance?
Thanks
Patty
Hi Patty -
I haven't heard of problems using Derby as you describe and think some
additional information would be helpful. There should be detailed
information in the derby.log file including a stack trace that will be
helpful in zeroing in on the problem. Posting the whole log will be a
help in knowing the version and if other issues are being reported.
Also, please describe how the processes (two?) that perform 1) the
bulk
load and 2) the inserts are initiated and synchronized.
------------------------------------------------------------------------
configFilename:
C:/bber2cc/parkerpx_ProcessingEngine/BBR2_comps/ProcessingEngine/Process
ingEngine/src/com/lexisnexis/batch/bber2/pe/config/config_pe_pooling.xml
log4j:WARN No appenders could be found for logger
(com.lexisnexis.batch.bber2.pe.ProcessingEngine).
log4j:WARN Please initialize the log4j system properly.
Loading Pools in PoolManager:
GenericObjectPool member type
com.lexisnexis.batch.bber2.pe.ProcessEngineController is : maxIdle = 76
| minIdle = 0 | maxActive = 300 | maxWait = -1 | testOnBorrow =
false | testOnReturn = false | testWhileIdle = false |
timeBetweenEvictionRunsMillis = -1 | numTestsPerEvictionRun = 3 |
minEvictableIdleTimeMillis = 1800000 | softMinEvictableIdleTimeMillis
= -1 | whenExhaustedAction = 1 |
1268 [Thread-0] DEBUG
com.lexisnexis.batch.bber2.pe.ProcessingEngineJMSClient - Attempting to
create a JMS Connection to: tcp://b10dhcp18147.lexis-nexis.com:61616
1660 [Thread-0] DEBUG
org.apache.activemq.transport.WireFormatNegotiator - Sending:
WireFormatInfo { version=1, properties={TightEncodingEnabled=true,
TcpNoDelayEnabled=true, SizePrefixDisabled=false,
StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true},
magic=[A,c,t,i,v,e,M,Q]}
1675 [ActiveMQ Transport:
tcp://b10dhcp18147.lexis-nexis.com/138.12.248.147:61616] DEBUG
org.apache.activemq.transport.WireFormatNegotiator - Received
WireFormat: WireFormatInfo { version=2,
properties={TightEncodingEnabled=true, CacheSize=1024,
TcpNoDelayEnabled=true, SizePrefixDisabled=false,
StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true},
magic=[A,c,t,i,v,e,M,Q]}
1675 [ActiveMQ Transport:
tcp://b10dhcp18147.lexis-nexis.com/138.12.248.147:61616] DEBUG
org.apache.activemq.transport.WireFormatNegotiator -
tcp://b10dhcp18147.lexis-nexis.com/138.12.248.147:61616 before
negotiation: OpenWireFormat{version=1, cacheEnabled=false,
stackTraceEnabled=false, tightEncodingEnabled=false,
sizePrefixDisabled=false}
1691 [ActiveMQ Transport:
tcp://b10dhcp18147.lexis-nexis.com/138.12.248.147:61616] DEBUG
org.apache.activemq.transport.WireFormatNegotiator -
tcp://b10dhcp18147.lexis-nexis.com/138.12.248.147:61616 after
negotiation: OpenWireFormat{version=1, cacheEnabled=true,
stackTraceEnabled=true, tightEncodingEnabled=true,
sizePrefixDisabled=false}
1722 [Thread-0] DEBUG
com.lexisnexis.batch.bber2.pe.ProcessingEngineJMSClient - JMS Init is
filling Consumer collection
2020 [Thread-0] DEBUG
com.lexisnexis.batch.bber2.pe.ProcessingEngineJMSClient - JMS Init is
filling Producer collection
2020 [Thread-0] DEBUG
com.lexisnexis.batch.bber2.pe.ProcessingEngineJMSClient - JMS Init is
firing the Initialize Event: init is valid = true
2020 [Thread-0] DEBUG
com.lexisnexis.batch.bber2.pe.ProcessingEngineJMSClient - JMS Client is
shutting down all Consumers
2067 [Thread-0] DEBUG com.lexisnexis.batch.bber2.pe.ProcessingEngine
- JMS init successful -- assigning producers and consumers
2223 [Thread-7] DEBUG org.apache.activemq.ActiveMQMessageConsumer -
Received message: MessageDispatch {commandId = 0, responseRequired =
false, consumerId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:1:2,
destination = queue://IPCtoPE, message = ActiveMQTextMessage {commandId
= 5, responseRequired = true, messageId =
ID:LNGDAYD-4133151-1560-1178723147277-0:0:1:1:1, originalDestination =
null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1560-1178723147277-0:0:1:1, destination =
queue://IPCtoPE, transactionId = null, expiration = 0, timestamp =
1178731026972, arrival = 0, correlationId = null, replyTo = null,
persistent = true, type = null, priority = 4, groupID = null,
groupSequence = 0, targetConsumerId = null, compressed = false, userID =
null, content = [EMAIL PROTECTED],
marshalledProperties = [EMAIL PROTECTED],
dataStructure = null, redeliveryCounter = 57, size = 0, properties =
null, readOnlyProperties = true, readOnlyBody = true, text = null},
redeliveryCounter = 57}
2239 [Thread-8] DEBUG ProcessingEngine - Received message:
ActiveMQTextMessage {commandId = 5, responseRequired = true, messageId =
ID:LNGDAYD-4133151-1560-1178723147277-0:0:1:1:1, originalDestination =
null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1560-1178723147277-0:0:1:1, destination =
queue://IPCtoPE, transactionId = null, expiration = 0, timestamp =
1178731026972, arrival = 0, correlationId = null, replyTo = null,
persistent = true, type = null, priority = 4, groupID = null,
groupSequence = 0, targetConsumerId = null, compressed = false, userID =
null, content = [EMAIL PROTECTED],
marshalledProperties = [EMAIL PROTECTED],
dataStructure = null, redeliveryCounter = 57, size = 0, properties =
null, readOnlyProperties = true, readOnlyBody = true, text = null}
2505 [Thread-8] DEBUG ProcessEngineController - In
ProcessEngineController
In ProcessEngineControllerObjectFactory, activateObject has been
called for com.lexisnexis.batch.bber2.pe.ProcessEngineController
2505 [Thread-8] DEBUG ProcessingEngine - Borrowed
ProcessEngineController contents:
[EMAIL PROTECTED]
2505 [Thread-8] DEBUG ProcessingEngine - Processor id:
[EMAIL PROTECTED]
2505 [pool-1-thread-1] DEBUG ProcessEngineController - Creating new
ListenableSimpleDirectedGraph
2583 [pool-1-thread-1] DEBUG GraphBuilder - In Graph Builder
XML file name:
C:\bber2cc\parkerpx_ProcessingEngine\BBR2_comps\ProcessingEngine\Process
ingEngine/src/com/lexisnexis/batch/bber2/pe/config/product.xml
2708 [pool-1-thread-1] DEBUG GraphBuilder - adding edge to graph -
fromNode: node1 ; toNode: node2
2724 [pool-1-thread-1] DEBUG GraphBuilder - Node: node2 Has this
Input File: node1out1
2724 [pool-1-thread-1] DEBUG GraphBuilder - adding edge to graph -
fromNode: node1 ; toNode: node3
2724 [pool-1-thread-1] DEBUG GraphBuilder - Node: node3 Has this
Input File: node1out1
2724 [pool-1-thread-1] DEBUG GraphBuilder - adding edge to graph -
fromNode: node2 ; toNode: node4
2724 [pool-1-thread-1] DEBUG GraphBuilder - Node: node4 Has this
Input File: node2out1
2724 [pool-1-thread-1] DEBUG GraphBuilder - adding edge to graph -
fromNode: node3 ; toNode: node4
2724 [pool-1-thread-1] DEBUG GraphBuilder - Node: node4 Has this
Input File: node3out1
graph object toString #1:
([EMAIL PROTECTED],
[EMAIL PROTECTED],
[EMAIL PROTECTED],
[EMAIL PROTECTED],
[EMAIL PROTECTED](com.l
[EMAIL PROTECTED],com.lexisnexi
[EMAIL PROTECTED]),
[EMAIL PROTECTED](com.l
[EMAIL PROTECTED],com.lexisnexi
[EMAIL PROTECTED]),
[EMAIL PROTECTED](com.le
[EMAIL PROTECTED],com.lexisnexis
[EMAIL PROTECTED]),
[EMAIL PROTECTED](com.le
[EMAIL PROTECTED],com.lexisnexis
[EMAIL PROTECTED])])
3585 [pool-1-thread-1] DEBUG GraphRunner - Running graph in
GraphRunner
DerbyDBManager starting in embedded mode.
4978 [pool-1-thread-1] DEBUG DerbyDBManager - Created connection
5369 [pool-1-thread-1] DEBUG DerbyDBManager - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.infolog.append','true')
5369 [pool-1-thread-1] DEBUG DerbyDBManager - Closed statement
5369 [pool-1-thread-1] DEBUG DerbyDBManager - closed connection
DerbyDBManager starting in embedded mode.
5369 [pool-1-thread-1] DEBUG DerbyDBManager - Created connection
5385 [pool-1-thread-1] DEBUG DerbyDBManager - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.language.logStatementText'
,'true')
5385 [pool-1-thread-1] DEBUG DerbyDBManager - Closed statement
5385 [pool-1-thread-1] DEBUG DerbyDBManager - closed connection
5385 [pool-1-thread-1] DEBUG DerbyDBManager - Loaded the
EmbeddedDriver.
Send this process to worker: node1
has this object name:
[EMAIL PROTECTED]
5651 [Thread-10] DEBUG org.apache.activemq.ActiveMQSession - Sending
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1, destination =
queue://PEToWorker, transactionId = null, expiration = 0, timestamp =
1178809141318, arrival = 0, correlationId = node1, replyTo =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:1, persistent =
true, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
null, marshalledProperties = null, dataStructure = null,
redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties =
true, readOnlyBody = true, text = <?xml version="1.0" encoding="UTF-8"
standalone="yes"?>
5870 [Thread-12] DEBUG org.apache.activemq.ActiveMQMessageConsumer -
Received message: MessageDispatch {commandId = 0, responseRequired =
false, consumerId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:3:2,
destination = queue://PEToWorker, message = ActiveMQTextMessage
{commandId = 22, responseRequired = true, messageId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1:1, originalDestination =
null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1, destination =
queue://PEToWorker, transactionId = null, expiration = 0, timestamp =
1178817011309, arrival = 0, correlationId = node1, replyTo =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:1, persistent =
true, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
[EMAIL PROTECTED], marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties
= null, readOnlyProperties = true, readOnlyBody = true, text = null},
redeliveryCounter = 0}
10472 [Thread-13] DEBUG DummyWorker - Dummy worker received this
message: <?xml version="1.0" encoding="UTF-8" standalone="yes"?>
10613 [Thread-13] DEBUG org.apache.activemq.ActiveMQSession - Sending
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:2:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:2, destination =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:1, transactionId
= null, expiration = 0, timestamp = 1178809146296, arrival = 0,
correlationId = node1, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter =
0, size = 0, properties =
{working_directory=C:/bber2cc/parkerpx_ProcessingEngine/BBR2_comps/Proce
ssingEngine/ProcessingEngine/testdata/input,
output_filename=node1worker.txt}, readOnlyProperties = true,
readOnlyBody = true, text = WORKER SAYS - IM DONE}
10707 [ActiveMQ Session Task] DEBUG ProcessDetailThread - Got My
Response for node1 from
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:1WORKER SAYS - IM
DONE
DerbyDBManager starting in embedded mode.
10722 [pool-1-thread-1] DEBUG GraphRunner - >>> Processing for node1
is really done <<<
10722 [pool-1-thread-1] DEBUG GraphRunner - From GraphRunner,
ProcessDetailThread no longer running
10722 [pool-1-thread-1] DEBUG GraphRunner - For Node: node1 --
connectorID: connectorId1 comes from node: node1 goes to node: node2
DerbyDBManager starting in embedded mode.
10769 [pool-1-thread-1] DEBUG DerbyDBManager - Created connection
10785 [ActiveMQ Session Task] DEBUG DerbyDBManager - Created
connection
10957 [pool-1-thread-1] DEBUG DerbyDBManager - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.infolog.append','true')
10957 [pool-1-thread-1] DEBUG DerbyDBManager - Closed statement
10957 [pool-1-thread-1] DEBUG DerbyDBManager - closed connection
DerbyDBManager starting in embedded mode.
10957 [pool-1-thread-1] DEBUG DerbyDBManager - Created connection
10988 [pool-1-thread-1] DEBUG DerbyDBManager - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.language.logStatementText'
,'true')
10988 [pool-1-thread-1] DEBUG DerbyDBManager - Closed statement
10988 [pool-1-thread-1] DEBUG DerbyDBManager - closed connection
10988 [pool-1-thread-1] DEBUG DerbyDBManager - Loaded the
EmbeddedDriver.
10988 [pool-1-thread-1] DEBUG GraphRunner - For Node: node1 --
connectorID: connectorId2 comes from node: node1 goes to node: node3
DerbyDBManager starting in embedded mode.
11004 [pool-1-thread-1] DEBUG DerbyDBManager - Created connection
11004 [connectorId1] DEBUG ConnectorDetailThread - in connector for
connectorId1
DerbyDBManager starting in embedded mode.
11004 [connectorId1] DEBUG DerbyDBManager - Created connection
11020 [pool-1-thread-1] DEBUG DerbyDBManager - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.infolog.append','true')
11020 [pool-1-thread-1] DEBUG DerbyDBManager - Closed statement
11020 [pool-1-thread-1] DEBUG DerbyDBManager - closed connection
DerbyDBManager starting in embedded mode.
11020 [pool-1-thread-1] DEBUG DerbyDBManager - Created connection
11035 [pool-1-thread-1] DEBUG DerbyDBManager - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.language.logStatementText'
,'true')
11035 [pool-1-thread-1] DEBUG DerbyDBManager - Closed statement
11035 [pool-1-thread-1] DEBUG DerbyDBManager - closed connection
11035 [pool-1-thread-1] DEBUG DerbyDBManager - Loaded the
EmbeddedDriver.
11067 [connectorId2] DEBUG ConnectorDetailThread - in connector for
connectorId2
DerbyDBManager starting in embedded mode.
11067 [connectorId2] DEBUG DerbyDBManager - Created connection
11677 [ActiveMQ Session Task] DEBUG DerbyDBManager - executed create
table node1(phone INTEGER,personNum INTEGER primary key,address
VARCHAR(254),firstName VARCHAR(254))
11677 [ActiveMQ Session Task] DEBUG DerbyDBManager - Closed
statement
11677 [ActiveMQ Session Task] DEBUG DerbyDBManager - closed
connection
11677 [ActiveMQ Session Task] DEBUG DerbyDBManager - Supposed to bulk
load these columns: PERSONNUM,FIRSTNAME,ADDRESS,PHONE
DerbyDBManager starting in embedded mode.
11677 [ActiveMQ Session Task] DEBUG DerbyDBManager - Created
connection
11849 [ActiveMQ Session Task] DEBUG DerbyDBManager - tableName: NODE1
11849 [ActiveMQ Session Task] DEBUG DerbyDBManager - insertColumn:
PERSONNUM,FIRSTNAME,ADDRESS,PHONE
11849 [ActiveMQ Session Task] DEBUG DerbyDBManager - columnIndexes:
null
11849 [ActiveMQ Session Task] DEBUG DerbyDBManager - inputFile:
C:/bber2cc/parkerpx_ProcessingEngine/BBR2_comps/ProcessingEngine/Process
ingEngine/testdata/input/node1worker.txt
11849 [ActiveMQ Session Task] DEBUG DerbyDBManager - columnDelimiter:
;
11849 [ActiveMQ Session Task] DEBUG DerbyDBManager - charDelimiter:
null
11896 [ActiveMQ Session Task] DEBUG DerbyDBManager - intReplace: 1
12460 [connectorId2] DEBUG DerbyDBManager - executed create table
connectorId2(phone INTEGER,personNum INTEGER primary key,address
VARCHAR(254),firstName VARCHAR(254))
12460 [connectorId2] DEBUG DerbyDBManager - Closed statement
12460 [connectorId2] DEBUG DerbyDBManager - closed connection
12460 [connectorId2] DEBUG ConnectorDetailThread - *** Heres the
nohit condition: SELECT * FROM ME.NODE1 WHERE PERSONNUM NOT IN (SELECT
PERSONNUM FROM ME.NODE1 WHERE NODE1.PERSONNUM > 100)
DerbyDBManager starting in embedded mode.
12491 [connectorId1] DEBUG DerbyDBManager - executed create table
connectorId1(phone INTEGER,personNum INTEGER primary key,address
VARCHAR(254),firstName VARCHAR(254))
15527 [connectorId2] DEBUG DerbyDBManager - Created connection
15527 [connectorId2] DEBUG DerbyDBManager - Insert statement: INSERT
INTO connectorId2 SELECT * FROM ME.NODE1 WHERE PERSONNUM NOT IN (SELECT
PERSONNUM FROM ME.NODE1 WHERE NODE1.PERSONNUM > 100)
15606 [connectorId1] DEBUG DerbyDBManager - Closed statement
15606 [connectorId1] DEBUG DerbyDBManager - closed connection
15621 [connectorId2] DEBUG DerbyDBManager - closed connection
16545 [connectorId1] DEBUG ConnectorDetailThread - *** Heres the hit
condition: SELECT * FROM ME.NODE1 WHERE NODE1.PERSONNUM > 100
DerbyDBManager starting in embedded mode.
16545 [connectorId1] DEBUG DerbyDBManager - Created connection
16545 [connectorId1] DEBUG DerbyDBManager - Insert statement: INSERT
INTO connectorId1 SELECT * FROM ME.NODE1 WHERE NODE1.PERSONNUM > 100
16561 [connectorId1] DEBUG DerbyDBManager - closed connection
DerbyDBManager starting in embedded mode.
16561 [pool-1-thread-1] DEBUG DerbyDBManager - Created connection
16561 [pool-1-thread-1] DEBUG DerbyDBManager - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.infolog.append','true')
16561 [pool-1-thread-1] DEBUG DerbyDBManager - Closed statement
16561 [pool-1-thread-1] DEBUG DerbyDBManager - closed connection
DerbyDBManager starting in embedded mode.
16561 [pool-1-thread-1] DEBUG DerbyDBManager - Created connection
16576 [pool-1-thread-1] DEBUG DerbyDBManager - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.language.logStatementText'
,'true')
16576 [pool-1-thread-1] DEBUG DerbyDBManager - Closed statement
16576 [pool-1-thread-1] DEBUG DerbyDBManager - closed connection
16576 [pool-1-thread-1] DEBUG DerbyDBManager - Loaded the
EmbeddedDriver.
Send this process to worker: node2
has this object name:
[EMAIL PROTECTED]
16780 [Thread-14] DEBUG org.apache.activemq.ActiveMQSession - Sending
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1:2,
originalDestination = null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1, destination =
queue://PEToWorker, transactionId = null, expiration = 0, timestamp =
1178809152463, arrival = 0, correlationId = node2, replyTo =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:2, persistent =
true, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
null, marshalledProperties = null, dataStructure = null,
redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties =
true, readOnlyBody = true, text = <?xml version="1.0" encoding="UTF-8"
standalone="yes"?>
17061 [Thread-16] DEBUG org.apache.activemq.ActiveMQMessageConsumer -
Received message: MessageDispatch {commandId = 0, responseRequired =
false, consumerId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:3:3,
destination = queue://PEToWorker, message = ActiveMQTextMessage
{commandId = 32, responseRequired = true, messageId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1:2, originalDestination =
null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1, destination =
queue://PEToWorker, transactionId = null, expiration = 0, timestamp =
1178817022432, arrival = 0, correlationId = node2, replyTo =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:2, persistent =
true, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
[EMAIL PROTECTED], marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties
= null, readOnlyProperties = true, readOnlyBody = true, text = null},
redeliveryCounter = 0}
25545 [Thread-18] DEBUG DummyWorker - Dummy worker received this
message: <?xml version="1.0" encoding="UTF-8" standalone="yes"?>
25889 [Thread-18] DEBUG org.apache.activemq.ActiveMQSession - Sending
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:3:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:3, destination =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:2, transactionId
= null, expiration = 0, timestamp = 1178809161572, arrival = 0,
correlationId = node2, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter =
0, size = 0, properties =
{working_directory=C:/bber2cc/parkerpx_ProcessingEngine/BBR2_comps/Proce
ssingEngine/ProcessingEngine/testdata/input,
output_filename=node2worker.txt}, readOnlyProperties = true,
readOnlyBody = true, text = WORKER SAYS - IM DONE}
25983 [ActiveMQ Session Task] DEBUG ProcessDetailThread - Got My
Response for node2 from
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:2WORKER SAYS - IM
DONE
DerbyDBManager starting in embedded mode.
25983 [ActiveMQ Session Task] DEBUG DerbyDBManager - Created
connection
25983 [pool-1-thread-1] DEBUG GraphRunner - >>> Processing for node2
is really done <<<
25983 [pool-1-thread-1] DEBUG GraphRunner - From GraphRunner,
ProcessDetailThread no longer running
25983 [pool-1-thread-1] DEBUG GraphRunner - For Node: node2 --
connectorID: connectorId1 comes from node: node1 goes to node: node2
25983 [pool-1-thread-1] DEBUG GraphRunner - For Node: node2 --
connectorID: connectorId3 comes from node: node2 goes to node: node4
DerbyDBManager starting in embedded mode.
25999 [pool-1-thread-1] DEBUG DerbyDBManager - Created connection
25999 [pool-1-thread-1] DEBUG DerbyDBManager - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.infolog.append','true')
25999 [pool-1-thread-1] DEBUG DerbyDBManager - Closed statement
25999 [pool-1-thread-1] DEBUG DerbyDBManager - closed connection
DerbyDBManager starting in embedded mode.
25999 [pool-1-thread-1] DEBUG DerbyDBManager - Created connection
26030 [pool-1-thread-1] DEBUG DerbyDBManager - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.language.logStatementText'
,'true')
26030 [pool-1-thread-1] DEBUG DerbyDBManager - Closed statement
26030 [pool-1-thread-1] DEBUG DerbyDBManager - closed connection
26030 [pool-1-thread-1] DEBUG DerbyDBManager - Loaded the
EmbeddedDriver.
26061 [connectorId3] DEBUG ConnectorDetailThread - in connector for
connectorId3
DerbyDBManager starting in embedded mode.
26061 [connectorId3] DEBUG DerbyDBManager - Created connection
26437 [ActiveMQ Session Task] DEBUG DerbyDBManager - executed create
table node2(empNum VARCHAR(254) primary key,sport VARCHAR(254),lastName
VARCHAR(254))
26437 [ActiveMQ Session Task] DEBUG DerbyDBManager - Closed
statement
26437 [ActiveMQ Session Task] DEBUG DerbyDBManager - closed
connection
26437 [ActiveMQ Session Task] DEBUG DerbyDBManager - Supposed to bulk
load these columns: EMPNUM,LASTNAME,SPORT
DerbyDBManager starting in embedded mode.
26515 [connectorId3] DEBUG DerbyDBManager - executed create table
connectorId3(empNum VARCHAR(254) primary key,sport VARCHAR(254),lastName
VARCHAR(254))
27846 [ActiveMQ Session Task] DEBUG DerbyDBManager - Created
connection
27846 [ActiveMQ Session Task] DEBUG DerbyDBManager - tableName: NODE2
27846 [ActiveMQ Session Task] DEBUG DerbyDBManager - insertColumn:
EMPNUM,LASTNAME,SPORT
27846 [ActiveMQ Session Task] DEBUG DerbyDBManager - columnIndexes:
null
27846 [ActiveMQ Session Task] DEBUG DerbyDBManager - inputFile:
C:/bber2cc/parkerpx_ProcessingEngine/BBR2_comps/ProcessingEngine/Process
ingEngine/testdata/input/node2worker.txt
27846 [connectorId3] DEBUG DerbyDBManager - Closed statement
27893 [ActiveMQ Session Task] DEBUG DerbyDBManager - columnDelimiter:
;
27908 [ActiveMQ Session Task] DEBUG DerbyDBManager - charDelimiter:
null
27908 [ActiveMQ Session Task] DEBUG DerbyDBManager - intReplace: 1
27924 [connectorId3] DEBUG DerbyDBManager - closed connection
27924 [connectorId3] DEBUG ConnectorDetailThread - *** Heres the all
condition: SELECT * FROM ME.NODE2
DerbyDBManager starting in embedded mode.
27924 [connectorId3] DEBUG DerbyDBManager - Created connection
27924 [connectorId3] DEBUG DerbyDBManager - Insert statement: INSERT
INTO connectorId3 SELECT * FROM ME.NODE2
28425 [connectorId3] DEBUG DerbyDBManager - closed connection
DerbyDBManager starting in embedded mode.
28425 [pool-1-thread-1] DEBUG DerbyDBManager - Created connection
28425 [pool-1-thread-1] DEBUG DerbyDBManager - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.infolog.append','true')
28425 [pool-1-thread-1] DEBUG DerbyDBManager - Closed statement
28441 [pool-1-thread-1] DEBUG DerbyDBManager - closed connection
DerbyDBManager starting in embedded mode.
28441 [pool-1-thread-1] DEBUG DerbyDBManager - Created connection
28441 [pool-1-thread-1] DEBUG DerbyDBManager - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.language.logStatementText'
,'true')
28441 [pool-1-thread-1] DEBUG DerbyDBManager - Closed statement
28441 [pool-1-thread-1] DEBUG DerbyDBManager - closed connection
28441 [pool-1-thread-1] DEBUG DerbyDBManager - Loaded the
EmbeddedDriver.
Send this process to worker: node3
has this object name:
[EMAIL PROTECTED]
28691 [Thread-19] DEBUG org.apache.activemq.ActiveMQSession - Sending
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1:3,
originalDestination = null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1, destination =
queue://PEToWorker, transactionId = null, expiration = 0, timestamp =
1178809164374, arrival = 0, correlationId = node3, replyTo =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:3, persistent =
true, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
null, marshalledProperties = null, dataStructure = null,
redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties =
true, readOnlyBody = true, text = <?xml version="1.0" encoding="UTF-8"
standalone="yes"?>
28863 [Thread-21] DEBUG org.apache.activemq.ActiveMQMessageConsumer -
Received message: MessageDispatch {commandId = 0, responseRequired =
false, consumerId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:3:4,
destination = queue://PEToWorker, message = ActiveMQTextMessage
{commandId = 42, responseRequired = true, messageId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1:3, originalDestination =
null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1, destination =
queue://PEToWorker, transactionId = null, expiration = 0, timestamp =
1178817034323, arrival = 0, correlationId = node3, replyTo =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:3, persistent =
true, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
[EMAIL PROTECTED], marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties
= null, readOnlyProperties = true, readOnlyBody = true, text = null},
redeliveryCounter = 0}
34576 [Thread-24] DEBUG DummyWorker - Dummy worker received this
message: <?xml version="1.0" encoding="UTF-8" standalone="yes"?>
34905 [Thread-24] DEBUG org.apache.activemq.ActiveMQSession - Sending
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:4:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:4, destination =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:3, transactionId
= null, expiration = 0, timestamp = 1178809170588, arrival = 0,
correlationId = node3, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter =
0, size = 0, properties =
{working_directory=C:/bber2cc/parkerpx_ProcessingEngine/BBR2_comps/Proce
ssingEngine/ProcessingEngine/testdata/input,
output_filename=node3worker.txt}, readOnlyProperties = true,
readOnlyBody = true, text = WORKER SAYS - IM DONE}
34905 [ActiveMQ Session Task] DEBUG ProcessDetailThread - Got My
Response for node3 from
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:3WORKER SAYS - IM
DONE
DerbyDBManager starting in embedded mode.
34905 [ActiveMQ Session Task] DEBUG DerbyDBManager - Created
connection
34921 [pool-1-thread-1] DEBUG GraphRunner - >>> Processing for node3
is really done <<<
34921 [pool-1-thread-1] DEBUG GraphRunner - From GraphRunner,
ProcessDetailThread no longer running
34921 [pool-1-thread-1] DEBUG GraphRunner - For Node: node3 --
connectorID: connectorId2 comes from node: node1 goes to node: node3
34921 [pool-1-thread-1] DEBUG GraphRunner - For Node: node3 --
connectorID: connectorId4 comes from node: node3 goes to node: node4
DerbyDBManager starting in embedded mode.
34921 [pool-1-thread-1] DEBUG DerbyDBManager - Created connection
34936 [pool-1-thread-1] DEBUG DerbyDBManager - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.infolog.append','true')
34936 [pool-1-thread-1] DEBUG DerbyDBManager - Closed statement
34936 [pool-1-thread-1] DEBUG DerbyDBManager - closed connection
DerbyDBManager starting in embedded mode.
34936 [pool-1-thread-1] DEBUG DerbyDBManager - Created connection
34952 [pool-1-thread-1] DEBUG DerbyDBManager - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.language.logStatementText'
,'true')
34952 [pool-1-thread-1] DEBUG DerbyDBManager - Closed statement
34952 [pool-1-thread-1] DEBUG DerbyDBManager - closed connection
34952 [pool-1-thread-1] DEBUG DerbyDBManager - Loaded the
EmbeddedDriver.
34952 [connectorId4] DEBUG ConnectorDetailThread - in connector for
connectorId4
DerbyDBManager starting in embedded mode.
34968 [connectorId4] DEBUG DerbyDBManager - Created connection
35202 [ActiveMQ Session Task] DEBUG DerbyDBManager - executed create
table node3(empNum VARCHAR(254) primary key,salary DOUBLE)
35202 [ActiveMQ Session Task] DEBUG DerbyDBManager - Closed
statement
35202 [ActiveMQ Session Task] DEBUG DerbyDBManager - closed
connection
35202 [ActiveMQ Session Task] DEBUG DerbyDBManager - Supposed to bulk
load these columns: EMPNUM,SALARY
DerbyDBManager starting in embedded mode.
35265 [ActiveMQ Session Task] DEBUG DerbyDBManager - Created
connection
35265 [ActiveMQ Session Task] DEBUG DerbyDBManager - tableName: NODE3
35265 [ActiveMQ Session Task] DEBUG DerbyDBManager - insertColumn:
EMPNUM,SALARY
35265 [ActiveMQ Session Task] DEBUG DerbyDBManager - columnIndexes:
null
35265 [ActiveMQ Session Task] DEBUG DerbyDBManager - inputFile:
C:/bber2cc/parkerpx_ProcessingEngine/BBR2_comps/ProcessingEngine/Process
ingEngine/testdata/input/node3worker.txt
35265 [ActiveMQ Session Task] DEBUG DerbyDBManager - columnDelimiter:
;
35375 [connectorId4] DEBUG DerbyDBManager - executed create table
connectorId4(empNum VARCHAR(254) primary key,salary DOUBLE)
37096 [ActiveMQ Session Task] DEBUG DerbyDBManager - charDelimiter:
null
37096 [ActiveMQ Session Task] DEBUG DerbyDBManager - intReplace: 1
37096 [connectorId4] DEBUG DerbyDBManager - Closed statement
37096 [connectorId4] DEBUG DerbyDBManager - closed connection
37096 [connectorId4] DEBUG ConnectorDetailThread - *** Heres the hit
condition: SELECT * FROM ME.NODE3 WHERE NODE3.SALARY > 10000
DerbyDBManager starting in embedded mode.
37300 [connectorId4] DEBUG DerbyDBManager - Created connection
37300 [connectorId4] DEBUG DerbyDBManager - Insert statement: INSERT
INTO connectorId4 SELECT * FROM ME.NODE3 WHERE NODE3.SALARY > 10000
37441 [connectorId4] DEBUG DerbyDBManager - exception thrown:
37441 [connectorId4] DEBUG DerbyDBManager - SQL Exception: Container
992 not found.
37441 [connectorId4] DEBUG DerbyDBManager - closed connection
DerbyDBManager starting in embedded mode.
37441 [pool-1-thread-1] DEBUG DerbyDBManager - Created connection
37472 [pool-1-thread-1] DEBUG DerbyDBManager - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.infolog.append','true')
37472 [pool-1-thread-1] DEBUG DerbyDBManager - Closed statement
37472 [pool-1-thread-1] DEBUG DerbyDBManager - closed connection
DerbyDBManager starting in embedded mode.
37472 [pool-1-thread-1] DEBUG DerbyDBManager - Created connection
37503 [pool-1-thread-1] DEBUG DerbyDBManager - executed CALL
SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY('derby.language.logStatementText'
,'true')
37503 [pool-1-thread-1] DEBUG DerbyDBManager - Closed statement
37503 [pool-1-thread-1] DEBUG DerbyDBManager - closed connection
37503 [pool-1-thread-1] DEBUG DerbyDBManager - Loaded the
EmbeddedDriver.
Send this process to worker: node4
has this object name:
[EMAIL PROTECTED]
37613 [Thread-25] DEBUG org.apache.activemq.ActiveMQSession - Sending
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1:4,
originalDestination = null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1, destination =
queue://PEToWorker, transactionId = null, expiration = 0, timestamp =
1178809173296, arrival = 0, correlationId = node4, replyTo =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:4, persistent =
true, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
null, marshalledProperties = null, dataStructure = null,
redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties =
true, readOnlyBody = true, text = <?xml version="1.0" encoding="UTF-8"
standalone="yes"?>
37863 [Thread-27] DEBUG org.apache.activemq.ActiveMQMessageConsumer -
Received message: MessageDispatch {commandId = 0, responseRequired =
false, consumerId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:3:5,
destination = queue://PEToWorker, message = ActiveMQTextMessage
{commandId = 52, responseRequired = true, messageId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1:4, originalDestination =
null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:1, destination =
queue://PEToWorker, transactionId = null, expiration = 0, timestamp =
1178817043222, arrival = 0, correlationId = node4, replyTo =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:4, persistent =
true, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
[EMAIL PROTECTED], marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties
= null, readOnlyProperties = true, readOnlyBody = true, text = null},
redeliveryCounter = 0}
42653 [Thread-31] DEBUG DummyWorker - Dummy worker received this
message: <?xml version="1.0" encoding="UTF-8" standalone="yes"?>
42888 [Thread-31] DEBUG org.apache.activemq.ActiveMQSession - Sending
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:5:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:6:5, destination =
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:4, transactionId
= null, expiration = 0, timestamp = 1178809178571, arrival = 0,
correlationId = node4, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter =
0, size = 0, properties =
{working_directory=C:/bber2cc/parkerpx_ProcessingEngine/BBR2_comps/Proce
ssingEngine/ProcessingEngine/testdata/input,
output_filename=node4worker.txt}, readOnlyProperties = true,
readOnlyBody = true, text = WORKER SAYS - IM DONE}
42888 [ActiveMQ Session Task] DEBUG ProcessDetailThread - Got My
Response for node4 from
temp-queue://ID:LNGDAYD-4133151-1744-1178809137076-1:0:4WORKER SAYS - IM
DONE
DerbyDBManager starting in embedded mode.
42903 [pool-1-thread-1] DEBUG GraphRunner - >>> Processing for node4
is really done <<<
42903 [pool-1-thread-1] DEBUG GraphRunner - From GraphRunner,
ProcessDetailThread no longer running
42903 [pool-1-thread-1] DEBUG GraphRunner - For Node: node4 --
connectorID: connectorId3 comes from node: node2 goes to node: node4
42903 [pool-1-thread-1] DEBUG GraphRunner - For Node: node4 --
connectorID: connectorId4 comes from node: node3 goes to node: node4
42903 [pool-1-thread-1] DEBUG ProcessEngineController - done running
GraphRunner
42903 [ActiveMQ Session Task] DEBUG DerbyDBManager - Created
connection
XML file name:
C:/bber2cc/parkerpx_OutputProc/BBR2_comps/OutputProcessing/OutputProcess
ingEngine/src/com/lexisnexis/batch/bber2/output/processor/config/new_out
put_instance.xml
43029 [Thread-8] DEBUG org.apache.activemq.ActiveMQSession - Sending
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = ID:LNGDAYD-4133151-1744-1178809137076-1:0:4:1:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1744-1178809137076-1:0:4:1, destination =
queue://PEtoOPE, transactionId = null, expiration = 0, timestamp =
1178809178712, arrival = 0, correlationId = null, replyTo = null,
persistent = true, type = null, priority = 4, groupID = null,
groupSequence = 0, targetConsumerId = null, compressed = false, userID =
null, content = null, marshalledProperties = null, dataStructure = null,
redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties =
true, readOnlyBody = true, text = <?xml version="1.0" encoding="UTF-8"?>
43060 [Thread-8] DEBUG ProcessingEngine - ActiveMQTextMessage
{commandId = 5, responseRequired = true, messageId =
ID:LNGDAYD-4133151-1560-1178723147277-0:0:1:1:1, originalDestination =
null, originalTransactionId = null, producerId =
ID:LNGDAYD-4133151-1560-1178723147277-0:0:1:1, destination =
queue://IPCtoPE, transactionId = null, expiration = 0, timestamp =
1178731026972, arrival = 0, correlationId = null, replyTo = null,
persistent = true, type = null, priority = 4, groupID = null,
groupSequence = 0, targetConsumerId = null, compressed = false, userID =
null, content = [EMAIL PROTECTED],
marshalledProperties = [EMAIL PROTECTED],
dataStructure = null, redeliveryCounter = 57, size = 0, properties =
null, readOnlyProperties = true, readOnlyBody = true, text = null}
43060 [Thread-8] DEBUG ProcessingEngine - ** Processor Resumes
Reading
43122 [ActiveMQ Session Task] DEBUG DerbyDBManager - executed create
table node4(payday DATE,empNum VARCHAR(254) primary key)
43122 [ActiveMQ Session Task] DEBUG DerbyDBManager - Closed
statement
43122 [ActiveMQ Session Task] DEBUG DerbyDBManager - closed
connection
43122 [ActiveMQ Session Task] DEBUG DerbyDBManager - Supposed to bulk
load these columns: EMPNUM,PAYDAY
DerbyDBManager starting in embedded mode.
43122 [ActiveMQ Session Task] DEBUG DerbyDBManager - Created
connection
43122 [ActiveMQ Session Task] DEBUG DerbyDBManager - tableName: NODE4
43122 [ActiveMQ Session Task] DEBUG DerbyDBManager - insertColumn:
EMPNUM,PAYDAY
43122 [ActiveMQ Session Task] DEBUG DerbyDBManager - columnIndexes:
null
43122 [ActiveMQ Session Task] DEBUG DerbyDBManager - inputFile:
C:/bber2cc/parkerpx_ProcessingEngine/BBR2_comps/ProcessingEngine/Process
ingEngine/testdata/input/node4worker.txt
43122 [ActiveMQ Session Task] DEBUG DerbyDBManager - columnDelimiter:
;
43122 [ActiveMQ Session Task] DEBUG DerbyDBManager - charDelimiter:
null
43122 [ActiveMQ Session Task] DEBUG DerbyDBManager - intReplace: 1
