112 Commits

Include renames

Author	SHA1	Message	Date
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
Axel Uhl	0a2c7fd422	serialize the operations when they are handed to replication service for broadcast; still group many byte[] into one message by delayed sending	2014-06-22 12:49:48 +02:00
Axel Uhl	1b7a4e4891	started working on bundling operations to replicate; still buggy as now the operations are serialized later, upon sending, and objects may have changed until then	2014-06-22 11:54:51 +02:00
Axel Uhl	6f2a77e9da	log operations per messages average	2014-06-22 11:06:27 +02:00
Axel Uhl	881cb39e9d	prepared the Replicator and ReplicationServiceImpl for replicating groups of operations in one sweep	2014-06-22 09:37:25 +02:00
Axel Uhl	212f40606f	simplified while-loop in Replicator	2014-06-22 09:22:51 +02:00
Simon Pamies	b927e4eebe	Added message about the selected messaging queue server	2014-06-07 14:15:16 +02:00
Axel Uhl	0c47e86304	moved Pair and Triple from com.sap.sailing.common.Util to com.sap.sse.common.Util and introduced all missing dependencies on com.sap.sse.common	2014-06-02 23:31:26 +02:00
fmittag	16df463800	Moved CountingOutputStream from a GWT/Java bundle (com.sapsailing.domain.common) to a pure java bundle due to GWT compile problems in the Eclipse IDE	2014-03-03 12:14:11 +01:00
Simon Pamies	2afb9366ec	Switched to properties because they are already supported by start ... script	2013-12-12 09:50:04 +01:00
Simon Pamies	2f9d9d8921	Fixed NPE for cases where a variable does not exist	2013-12-12 09:50:00 +01:00
Simon Pamies	8c1d23871f	Removed imports	2013-12-12 09:25:09 +01:00
Simon Pamies	d9552300ab	Added automatic replication startup based on configuration from env.sh	2013-12-12 09:25:08 +01:00
Axel Uhl	3f20168986	mocked enough of the OSGi service fetching in SailingServiceImpl to let testPolarSheetGenerationService run green again	2013-12-06 09:44:17 +01:00
Axel Uhl	3542cf7e67	using a GzipOutputStream to compress initial replication; results in a factor of 4 compression, roughly	2013-11-19 11:27:57 +01:00
Axel Uhl	cf6aeba9d6	use a filtering output stream for initial load serialization, so that on the server we can see the data volume caused by the initial load	2013-11-18 17:24:36 +01:00
Axel Uhl	2be40c66f8	Merge branch 'master' into persistentCompetitors ... Conflicts: java/com.sap.sailing.gwt.ui/src/main/java/com/sap/sailing/gwt/ui/client/StringMessages.java	2013-10-31 18:19:45 +01:00
Simon Pamies	a82a93e6af	Extended logging to be able to see which server we're using	2013-10-31 15:55:44 +01:00
Simon Pamies	25f43f8710	Using replication hostname when connectiong to queue	2013-10-31 15:53:58 +01:00
Simon Pamies	204a61ee5e	Fixed replication master implementation to make sure that master server and replication server can be two different hosts	2013-10-31 15:20:41 +01:00
Simon Pamies	e4e510a5eb	Made replication tests aware of environment variables	2013-10-31 14:29:47 +01:00
Simon Pamies	07d4ec2da3	Making sure that replication service honors environmnt variables	2013-10-31 12:59:43 +01:00
Axel Uhl	3da17302f8	removed DomainFactory.INSTANCE use except from test cases; renamed MongoFactory to PersistenceFactory	2013-10-28 17:26:26 +01:00
Axel Uhl	f1fa1d74f6	moved a few more distance and speed types to domain.common and fixed a grave bug in MeterPerSecondSpeed; added test for improved outlier filtering	2013-08-14 18:00:45 +02:00
fmittag	3a375c3d3a	initial version of jetty9 support	2013-08-06 14:23:26 +02:00
Simon Pamies	b608a6351e	Updated replication connector to use product based host property	2013-07-12 17:47:03 +02:00
Simon Pamies	9f47801d77	Make sure that queue is cleared properly after each test	2013-06-21 13:50:06 +02:00
Simon Pamies	8fd0141f03	Fixed naming of queue parameter	2013-06-21 12:22:24 +02:00
Simon Pamies	25a46ef312	Revamped functionality of removing a queue. It works now correctly and ... removes queues.	2013-06-21 01:50:58 +02:00
Simon Pamies	464d7d2051	Now also the queue will survive a connection drop and will also handle ... client disconnects gracefully and free contents after some time.	2013-06-21 01:25:47 +02:00
Simon Pamies	1cf09573e0	Logging exceptions the right way	2013-06-20 23:23:05 +02:00
Simon Pamies	393c65d2d9	Avoid deprecation by simply using encoding	2013-06-20 23:22:40 +02:00
Simon Pamies	b994b71236	Minor changes like i18n and functionality for stopping one replica	2013-06-20 23:14:37 +02:00
Simon Pamies	4033f0e25b	Encoding parameters correctly, also using identifier instead of hostname	2013-06-20 16:09:54 +02:00
Simon Pamies	af09da2d7f	Now an error does no longer yield information about a master	2013-06-20 15:45:40 +02:00