Commits

Boris FELD committed 2d5852a

Remove old files

Comments (0)

Files changed (4)

src/zeromq/src/main/java/org/janusproject/kernel/network/zeromq/demo/SampleMessage.java

-package org.janusproject.kernel.network.zeromq.demo;
-
-import org.janusproject.kernel.message.Message;
-
-public class SampleMessage extends Message {
-
-	@Override
-	public String toString() {
-		return "SampleMessage [Coucou]";
-	}
-
-	/**
-	 * 
-	 */
-	private static final long serialVersionUID = 6864296736795866242L;
-
-}

src/zeromq/src/main/java/org/janusproject/kernel/network/zeromq/demo/SampleReceiver.java

-package org.janusproject.kernel.network.zeromq.demo;
-
-import java.util.logging.Level;
-import java.util.logging.Logger;
-
-import org.janusproject.kernel.Kernel;
-import org.janusproject.kernel.agent.Agent;
-import org.janusproject.kernel.agent.Kernels;
-import org.janusproject.kernel.logger.LoggerUtil;
-import org.janusproject.kernel.message.Message;
-import org.janusproject.kernel.network.zeromq.agent.ZeroMQKernelAgentFactory;
-import org.janusproject.kernel.status.Status;
-import org.janusproject.kernel.status.StatusFactory;
-
-public class SampleReceiver extends Agent {
-
-	/**
-	 * 
-	 */
-	private static final long serialVersionUID = -7927590902038071289L;
-
-	@Override
-	public Status live() {
-
-		Message aMsg = getMessage();
-
-		if (aMsg != null) {
-
-			Logger logger = Logger.getAnonymousLogger();
-
-			logger.log(Level.INFO, aMsg.toString()); //$NON-NLS-1$
-
-			this.killMe();
-		}
-
-		return StatusFactory.ok(this);
-	}
-
-	public static void main(String[] args) {
-
-		LoggerUtil.setGlobalLevel(Level.ALL);
-		LoggerUtil.setShortLogMessageEnable(true);
-
-		Kernels.setPreferredKernelFactory(new ZeroMQKernelAgentFactory());
-		Kernel k = Kernels.get(false);
-
-		SampleReceiver receiver = new SampleReceiver();
-
-		k.submitLightAgent(receiver, "RECEIVER"); //$NON-NLS-1$
-
-		k.launchDifferedExecutionAgents();
-	}
-
-}

src/zeromq/src/main/java/org/janusproject/kernel/network/zeromq/demo/SampleSender.java

-package org.janusproject.kernel.network.zeromq.demo;
-
-import java.util.logging.Level;
-import java.util.logging.Logger;
-
-import org.janusproject.kernel.Kernel;
-import org.janusproject.kernel.address.AgentAddress;
-import org.janusproject.kernel.agent.Agent;
-import org.janusproject.kernel.agent.Kernels;
-import org.janusproject.kernel.logger.LoggerUtil;
-import org.janusproject.kernel.message.Message;
-import org.janusproject.kernel.network.zeromq.agent.ZeroMQKernelAgentFactory;
-import org.janusproject.kernel.status.Status;
-import org.janusproject.kernel.status.StatusFactory;
-import org.janusproject.kernel.util.sizediterator.SizedIterator;
-
-public class SampleSender extends Agent {
-
-	/**
-	 * 
-	 */
-	private static final long serialVersionUID = -2744019475608390295L;
-	
-	boolean isSent = false;
-	
-	public Status live() {
-
-		Message message = new SampleMessage();
-		SizedIterator<AgentAddress> agents = getLocalAgents();
-		
-		if (!this.isSent) {
-			while (agents.hasNext()) {
-				AgentAddress agent = agents.next();
-				if (agent != getAddress()) {
-					sendMessage(message, agent);
-					Logger logger = Logger.getAnonymousLogger();
-
-					logger.log(Level.INFO, message.toString());
-					this.isSent = true;
-				}
-			}
-		}  else {
-			this.killMe();
-		}
-		
-		return StatusFactory.ok(this);
-		
-	}
-
-	public static void main(String[] args) {
-		
-		LoggerUtil.setGlobalLevel(Level.ALL);
-		LoggerUtil.setShortLogMessageEnable(true);
-
-		Kernels.setPreferredKernelFactory(new ZeroMQKernelAgentFactory());
-		Kernel k = Kernels.get( false );
-		
-		SampleSender sender = new SampleSender();
-		
-		k.submitLightAgent(sender, "SENDER"); //$NON-NLS-1$
-		
-		k.launchDifferedExecutionAgents();
-	}	
-
-}

src/zeromq/src/main/java/org/janusproject/kernel/network/zeromq/zeromq/ZeroMQNodePeerRepository.java

-package org.janusproject.kernel.network.zeromq.zeromq;
-
-import java.util.UUID;
-
-import org.janusproject.kernel.repository.ConcurrentHashRepository;
-
-public class ZeroMQNodePeerRepository extends ConcurrentHashRepository<UUID, ZeroMQPeerNode> {
-
-}
Tip: Filter by directory path e.g. /media app.js to search for public/media/app.js.
Tip: Use camelCasing e.g. ProjME to search for ProjectModifiedEvent.java.
Tip: Filter by extension type e.g. /repo .js to search for all .js files in the /repo directory.
Tip: Separate your search with spaces e.g. /ssh pom.xml to search for src/ssh/pom.xml.
Tip: Use ↑ and ↓ arrow keys to navigate and return to view the file.
Tip: You can also navigate files with Ctrl+j (next) and Ctrl+k (previous) and view the file with Ctrl+o.
Tip: You can also navigate files with Alt+j (next) and Alt+k (previous) and view the file with Alt+o.