litesoft

URLs

Explore

Commits

Diff Revisions 948 vs 950 for /trunk/Java/GWT/OldServer/src/org/litesoft/GWT/eventbus/server/nonpublic/NonTemporaryServerEventBus.java

		@@ -1,42 +1,42 @@
1		-	// This Source Code is in the Public Domain per: http://unlicense.org
2		-	package org.litesoft.GWT.eventbus.server.nonpublic;
3		-
4		-	import org.litesoft.GWT.eventbus.client.nonpublic.*;
5		-	import org.litesoft.GWT.eventbus.server.*;
6		-	import org.litesoft.logger.*;
7		-
8		-	public abstract class NonTemporaryServerEventBus extends ServerEventBus {
9		-	protected NonTemporaryServerEventBus( int pClientIdNumber ) {
10		-	super( pClientIdNumber );
11		-	}
12		-
13		-	public synchronized ServerSideRemotePeerService initialize( String pWhy ) {
14		-	Logger logger = createLogger();
15		-	ServerSideRemotePeerService rv = new ServerSideRemotePeerService( logger, this );
16		-	mRemotePeerService = rv;
17		-	initialize( logger, new StatePeerSupportingEventBusRegular( logger, //
18		-	this, this, this,
19		-	new ProcessingManagerServerImpl(),
20		-	mRemotePeerService ) );
21		-	// For Browser Data use the current SEB if there is one (might be a Temp)
22		-	ServerEventBus zCurrentBus = ServerEventBusManager.INSTANCE.getServerEventBus( getClientIdNumber() );
23		-	sharedInitialization( pWhy, ServerEventBusManager.INSTANCE.getParentClientID( getClientIdNumber() ), (
24		-	zCurrentBus != null) ?
25		-	zCurrentBus.getClientWindowInstanceDataManager() :
26		-	null );
27		-	return rv;
28		-	}
29		-
30		-	private RemotePeerService mRemotePeerService;
31		-
32		-	public synchronized RemotePeerService getRemotePeerService() {
33		-	return mRemotePeerService;
34		-	}
35		-
36		-	protected void LLdispose( String pWhy ) {
37		-	synchronized ( this ) {
38		-	mRemotePeerService = RemotePeerService.Null.INSTANCE;
39		-	}
40		-	super.LLdispose( pWhy );
41		-	}
42		-	}
	1	+	// This Source Code is in the Public Domain per: http://unlicense.org
	2	+	package org.litesoft.GWT.eventbus.server.nonpublic;
	3	+
	4	+	import org.litesoft.GWT.eventbus.client.nonpublic.*;
	5	+	import org.litesoft.GWT.eventbus.server.*;
	6	+	import org.litesoft.logger.*;
	7	+
	8	+	public abstract class NonTemporaryServerEventBus extends ServerEventBus {
	9	+	protected NonTemporaryServerEventBus( int pClientIdNumber ) {
	10	+	super( pClientIdNumber );
	11	+	}
	12	+
	13	+	public synchronized ServerSideRemotePeerService initialize( String pWhy ) {
	14	+	Logger logger = createLogger();
	15	+	ServerSideRemotePeerService rv = new ServerSideRemotePeerService( logger, this );
	16	+	mRemotePeerService = rv;
	17	+	initialize( logger, new StatePeerSupportingEventBusRegular( logger, //
	18	+	this, this, this,
	19	+	new ProcessingManagerServerImpl(),
	20	+	mRemotePeerService ) );
	21	+	// For Browser Data use the current SEB if there is one (might be a Temp)
	22	+	ServerEventBus zCurrentBus = ServerEventBusManager.INSTANCE.getServerEventBus( getClientIdNumber() );
	23	+	sharedInitialization( pWhy, ServerEventBusManager.INSTANCE.getParentClientID( getClientIdNumber() ), (
	24	+	zCurrentBus != null) ?
	25	+	zCurrentBus.getClientWindowInstanceDataManager() :
	26	+	null );
	27	+	return rv;
	28	+	}
	29	+
	30	+	private RemotePeerService mRemotePeerService;
	31	+
	32	+	public synchronized RemotePeerService getRemotePeerService() {
	33	+	return mRemotePeerService;
	34	+	}
	35	+
	36	+	protected void LLdispose( String pWhy ) {
	37	+	synchronized ( this ) {
	38	+	mRemotePeerService = RemotePeerService.Null.INSTANCE;
	39	+	}
	40	+	super.LLdispose( pWhy );
	41	+	}
	42	+	}

View View this file contents

History View the full history

Feeds

Commits for /trunk/Java/GWT/OldServer/src/org/litesoft/GWT/eventbus/server/nonpublic/NonTemporaryServerEventBus.java