Commit Graph
146 Commits
Author SHA1 Message Date
Axel Uhl b62d566953 broken interims commit; has some parts of the refactoring of the AdminConsolePanel already 2014-11-06 15:03:56 +01:00
Axel Uhl 86e005d32c solution for bug 2437: clear the replica's state before registering for operation updates which needs to happen before requesting the initial load 2014-10-28 15:47:51 +01:00
Axel Uhl 69de0f2d76 upgraded project settings to Java8, fixed gwt.ui to JavaSE-1.7 explicitly 2014-10-01 15:00:44 +02:00
Axel Uhl 161d823dee updated project compliance settings to JavaSE-1.8 2014-10-01 14:44:22 +02:00
Axel Uhl e9130d38f3 upgraded classpaths to JavaSE-1.8 2014-10-01 14:16:18 +02:00
Axel Uhl 7ece44052d upgraded manifests from JavaSE-1.7 to JavaSE-1.8 as runtime environment 2014-10-01 14:08:19 +02:00
Axel Uhl 47dedb2437 use the master exchange name as the default value for replicate.master.exchange.name for backward compatibility and ease of use 2014-09-26 11:06:35 +02:00
Axel Uhl 2326df3688 improved comments for replication parameters; use 0 as default port for automatic replication 2014-09-26 10:53:56 +02:00
Axel Uhl 0fe1c8c4e0 introduced property to configure the exchange name for automatic replication start 2014-09-26 10:43:30 +02:00
Axel Uhl e49193b3e2 worked on replication Javadoc and improved toString() and log outputs regarding messaging vs. servlet hostname 2014-09-26 09:39:19 +02:00
Steffen Wagner (d059727) 935fcb5722 fixed bug #2087 by passing a new parameter from the startscript to the replication Activator (reverted from commit 55675ad21a) 2014-07-24 11:48:23 +02:00
Axel Uhl 0e7086e9fd replaced tab by spaces 2014-07-23 23:19:39 +02:00
Steffen Wagner (d059727) 55675ad21a fixed bug #2087 by passing a new parameter from the startscript to the replication Activator 2014-07-23 18:14:02 +02:00
Axel Uhl 4707d527ab disable directory listing for further web bundles 2014-07-21 23:58:37 +02:00
Axel Uhl 807c0f8da5 while working down the queued replicated operations, catch and log exception per operation, then continue 2014-07-21 12:45:49 +02:00
Axel Uhl 094dcb6216 deleting initialLoad queue when done 2014-07-20 19:34:17 +02:00
Axel Uhl 552a2b794d Merge branch 'bug2026'
Conflicts:
	java/com.sap.sailing.server.replication/src/com/sap/sailing/server/replication/impl/ReplicationServiceImpl.java
2014-07-17 19:46:31 +02:00
Axel Uhl 2b36374b2f moved CountingOutputStream again away from com.sap.sse.common because its base class FilterOutputStream is not available in GWT's JRE emulation 2014-07-17 13:49:27 +02:00
Axel Uhl 69c4d7604f avoid NPE in the unlikely case where two timer tasks are scheduled concurrently or the buffer got sent early based on size 2014-07-17 13:03:11 +02:00
Axel Uhl af8168a670 Merge branch 'master' into bug2026 2014-07-17 01:53:51 +02:00
Axel Uhl 15b4497540 use GZIP compression also for regular replication operations; by bundling several operations into one message, this could pay off 2014-07-17 01:52:45 +02:00
Axel Uhl 96ca743b2c another minor replication logging change 2014-07-17 01:36:11 +02:00
Axel Uhl 8a8dec05b7 minor replication logging change 2014-07-17 01:34:31 +02:00
Axel Uhl 5fc172a15d send operations before delay has passed if buffer exceeds 1MB; made timer task exception-safe 2014-07-17 01:08:09 +02:00
Axel Uhl f36df6af13 added test that shows that an exception in a TimerTask cancels the timer and makes it unusable 2014-07-17 00:46:50 +02:00
Axel Uhl 8cb4b7f548 adjusted replication log message 2014-07-16 23:37:29 +02:00
Axel Uhl 6356a2b6d9 fixed replication log message 2014-07-16 23:32:28 +02:00
Axel Uhl 8f1c888f06 write buffered operations into stream directly, avoiding copying the potentially huge message buffer; more replication logging still 2014-07-16 23:00:09 +02:00
Axel Uhl 74aab09c6f more replication logging for FINE level 2014-07-16 21:31:25 +02:00
Axel Uhl 91ae53f6c5 more replication logging 2014-07-16 16:32:27 +02:00
Axel Uhl 5410a6e871 fix for bug 1937 comment #7: the connection to RabbitMQ needs to consider that RabbitMQ may be running somewhere else; use ReplicationService.createMasterChannel() 2014-07-16 15:27:40 +02:00
Simon Pamies d640b5c1ea Added more logging 2014-07-16 12:07:30 +02:00
Simon Pamies 732dac0da5 Added more logging and show how many messages have been sent 2014-07-16 11:42:54 +02:00
Simon Pamies 277f8c6a05 Moved CountingOutputStream to com.sap.sse.common to make it reusable 2014-07-16 11:42:14 +02:00
Axel Uhl d7b09a14e1 improved logging for outbound replication queue 2014-07-16 10:14:58 +02:00
Axel Uhl 2dd7ad0a79 improved logging for sending initial load 2014-07-15 17:06:17 +02:00
Axel Uhl 09b4a30a9c fixed initial-load queue name, making it unique 2014-07-15 15:30:40 +02:00
Axel Uhl a9c1c147b2 use a unique test queue name for each initial load test 2014-06-26 15:53:12 +02:00
Axel Uhl 4eb4241a96 Merge branch 'master' into improved-replication
Conflicts:
	java/com.sap.sailing.server.replication/src/com/sap/sailing/server/replication/impl/Replicator.java
2014-06-26 14:55:37 +02:00
Axel Uhl 216c2e5cdd support concurrent replication operation execution for wind fixes and competitor and mark fixes; fixing bug 2020 2014-06-25 23:28:37 +02:00
Axel Uhl 148f7936f2 log size of inbound replication queue (number of received by yet unprocessed messages) 2014-06-25 23:10:45 +02:00
Axel Uhl e090c78f7f pass queue name to RabbitOutputStream; letting the server choose a queue name only works for exclusive queues which is not what we need here 2014-06-24 23:33:14 +02:00
Axel Uhl aaa6955fac converting initial load to using RabbitOutputStream and RabbitInputStream 2014-06-24 15:50:02 +02:00
Axel Uhl 6a8501e5a2 made the RabbitOutputStream safe for sending the termination message on purpose in the payload 2014-06-24 13:37:18 +02:00
Axel Uhl dcdc33a556 added failing test case for terminator transmission; the terminator needs to be escaped 2014-06-24 13:13:44 +02:00
Axel Uhl c882fc1a0b added a test that works based on the messaging timeout 2014-06-24 12:56:58 +02:00
Axel Uhl b88ef0eb0d added a test case that sends data that needs to be split into two messages 2014-06-24 12:49:27 +02:00
Axel Uhl 3611d4e6ff a first successful mini-test for streaming through RabbitMQ 2014-06-24 12:09:08 +02:00
Axel Uhl 99145a5c96 started with some refactoring and added a number of comments for things that need fixing with the AMPQ streaming 2014-06-24 10:39:28 +02:00
Axel Uhl afe6430adc beginning to implement InputStream/OutputStream across a RabbitMQ queue that splits the stream into messages; this commit based on Simon's proposals on bug 1937 2014-06-24 10:05:15 +02:00