← Back to branch summary

~ubuntu-branches/ubuntu/trusty/ehcache/trusty

« back to all changes in this revision

Viewing changes to src/main/java/net/sf/ehcache/distribution/RMICachePeer.java

  • Committer: Package Import Robot
  • Author(s): Emmanuel Bourg
  • Date: 2013-05-06 14:53:07 UTC
  • mfrom: (1.1.7) (2.1.8 sid)
  • Revision ID: package-import@ubuntu.com-20130506145307-v5bhw5yu70re00l3
Tags: 2.6.7-1
* Team upload.
* New upstream release

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/main/java/net/sf/ehcache/distribution/RMICachePeer.java
1
1
/**
2
 
 *  Copyright 2003-2010 Terracotta, Inc.
 
2
 *  Copyright Terracotta, Inc.
3
3
 *
4
4
 *  Licensed under the Apache License, Version 2.0 (the "License");
5
5
 *  you may not use this file except in compliance with the License.
25
25
import java.rmi.server.UnicastRemoteObject;
26
26
import java.util.ArrayList;
27
27
import java.util.List;
 
28
import net.sf.ehcache.distribution.RmiEventMessage.RmiEventType;
28
29
 
29
30
import org.slf4j.Logger;
30
31
import org.slf4j.LoggerFactory;
35
36
 * This class features a customised RMIClientSocketFactory which enables socket timeouts to be configured.
36
37
 *
37
38
 * @author Greg Luck
38
 
 * @version $Id: RMICachePeer.java 4259 2011-07-01 13:34:54Z cdennis $
 
39
 * @version $Id: RMICachePeer.java 5631 2012-05-10 08:31:33Z teck $
39
40
 */
40
41
public class RMICachePeer extends UnicastRemoteObject implements CachePeer, Remote {
41
42
 
215
216
     */
216
217
    public void send(List eventMessages) throws RemoteException {
217
218
        for (int i = 0; i < eventMessages.size(); i++) {
218
 
            EventMessage eventMessage = (EventMessage) eventMessages.get(i);
219
 
            if (eventMessage.getEvent() == EventMessage.PUT) {
 
219
            RmiEventMessage eventMessage = (RmiEventMessage) eventMessages.get(i);
 
220
            if (eventMessage.getType() == RmiEventType.PUT) {
220
221
                put(eventMessage.getElement());
221
 
            } else if (eventMessage.getEvent() == EventMessage.REMOVE) {
 
222
            } else if (eventMessage.getType() == RmiEventType.REMOVE) {
222
223
                remove(eventMessage.getSerializableKey());
223
 
            } else if (eventMessage.getEvent() == EventMessage.REMOVE_ALL) {
 
224
            } else if (eventMessage.getType() == RmiEventType.REMOVE_ALL) {
224
225
                removeAll();
225
226
            } else {
226
227
                LOG.error("Unknown event: " + eventMessage);