org.ow2.petals.registry.core.manager
Class GenericIncomingManagerImpl

java.lang.Object
  extended by org.ow2.petals.registry.core.manager.GenericIncomingManagerImpl
All Implemented Interfaces:
org.ow2.petals.registry.api.lifecycle.LifeCycle, org.ow2.petals.registry.api.manager.IncomingManager, org.ow2.petals.registry.api.manager.IOManager, org.ow2.petals.registry.api.RemoteOperations

public class GenericIncomingManagerImpl
extends java.lang.Object
implements org.ow2.petals.registry.api.manager.IncomingManager

An abstract local manager is used to handle incoming messages from remote registries.

Author:
Christophe HAMERLING - eBM WebSourcing

Nested Class Summary
 
Nested classes/interfaces inherited from interface org.ow2.petals.registry.api.lifecycle.LifeCycle
org.ow2.petals.registry.api.lifecycle.LifeCycle.STATE
 
Field Summary
protected  org.ow2.petals.registry.api.lifecycle.AbstractLifeCycle lifeCycle
           
protected  org.ow2.petals.registry.api.LocalRegistry localRegistry
           
protected  java.lang.String name
           
protected  boolean receive
           
 
Constructor Summary
GenericIncomingManagerImpl()
          Creates a new instance of AbstractIncomingManager
 
Method Summary
protected  void checkPath(java.lang.String path)
           
protected  void checkReceive()
           
protected  void checkSource(org.ow2.petals.registry.api.Information information)
          Check that the resource can be received by the current registry.
 boolean delete(java.lang.String path, org.ow2.petals.registry.api.Information information)
           
protected  boolean doDelete(java.lang.String key)
           
protected  org.ow2.petals.registry.api.Resource doGet(java.lang.String path)
           
protected  java.util.List<org.ow2.petals.registry.api.Resource> doGetAll(java.lang.String path)
           
protected  boolean doPut(java.lang.String key, org.ow2.petals.registry.api.Resource resource)
           
protected  java.util.List<org.ow2.petals.registry.api.Resource> doQuery(org.ow2.petals.registry.api.Query query)
           
 org.ow2.petals.registry.api.Resource get(java.lang.String path, org.ow2.petals.registry.api.Information information)
           
 java.util.List<org.ow2.petals.registry.api.Resource> getAll(java.lang.String path, org.ow2.petals.registry.api.Information information)
           
 org.ow2.petals.registry.api.LocalRegistry getLocalRegistry()
           
 java.lang.String getName()
           
 org.ow2.petals.registry.api.lifecycle.LifeCycle.STATE getState()
           
 void init(org.ow2.petals.registry.api.context.Context context)
           
 boolean isInitialized()
           
 boolean isNotInitialized()
           
 boolean isRunning()
           
 boolean isStarted()
           
 boolean isStopped()
           
 void pause()
           
 boolean put(java.lang.String path, org.ow2.petals.registry.api.Resource resource, org.ow2.petals.registry.api.Information information)
           
 java.util.List<org.ow2.petals.registry.api.Resource> query(org.ow2.petals.registry.api.Query query, org.ow2.petals.registry.api.Information information)
           
 void resume()
           
protected  void setLifeCycle(org.ow2.petals.registry.api.lifecycle.AbstractLifeCycle lifeCycle)
           
 void setLocalRegistry(org.ow2.petals.registry.api.LocalRegistry localRegistry)
           
 void setName(java.lang.String name)
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

lifeCycle

protected org.ow2.petals.registry.api.lifecycle.AbstractLifeCycle lifeCycle

localRegistry

protected org.ow2.petals.registry.api.LocalRegistry localRegistry

name

protected java.lang.String name

receive

protected boolean receive
Constructor Detail

GenericIncomingManagerImpl

public GenericIncomingManagerImpl()
Creates a new instance of AbstractIncomingManager

Parameters:
incomingMessageDispatcher -
Method Detail

getName

public java.lang.String getName()

setName

public void setName(java.lang.String name)

getLocalRegistry

public org.ow2.petals.registry.api.LocalRegistry getLocalRegistry()
Specified by:
getLocalRegistry in interface org.ow2.petals.registry.api.manager.IOManager

setLocalRegistry

public void setLocalRegistry(org.ow2.petals.registry.api.LocalRegistry localRegistry)
                      throws org.ow2.petals.registry.api.exception.LifeCycleException
Specified by:
setLocalRegistry in interface org.ow2.petals.registry.api.manager.IOManager
Throws:
org.ow2.petals.registry.api.exception.LifeCycleException

pause

public void pause()
Specified by:
pause in interface org.ow2.petals.registry.api.manager.IncomingManager

resume

public void resume()
Specified by:
resume in interface org.ow2.petals.registry.api.manager.IncomingManager

checkReceive

protected void checkReceive()
                     throws org.ow2.petals.registry.api.exception.ReceptionException
Throws:
org.ow2.petals.registry.api.exception.ReceptionException

checkPath

protected void checkPath(java.lang.String path)
                  throws org.ow2.petals.registry.api.exception.RegistryException
Throws:
org.ow2.petals.registry.api.exception.RegistryException

checkSource

protected void checkSource(org.ow2.petals.registry.api.Information information)
                    throws org.ow2.petals.registry.api.exception.RegistryException
Check that the resource can be received by the current registry. A basic rule is that a resource created on the local registry can not be received by the same...

Parameters:
resource -
Throws:
org.ow2.petals.registry.api.exception.RegistryException

get

public final org.ow2.petals.registry.api.Resource get(java.lang.String path,
                                                      org.ow2.petals.registry.api.Information information)
                                               throws org.ow2.petals.registry.api.exception.RegistryException
Specified by:
get in interface org.ow2.petals.registry.api.RemoteOperations
Throws:
org.ow2.petals.registry.api.exception.RegistryException

doGet

protected org.ow2.petals.registry.api.Resource doGet(java.lang.String path)
                                              throws org.ow2.petals.registry.api.exception.RegistryException
Throws:
org.ow2.petals.registry.api.exception.RegistryException

put

public final boolean put(java.lang.String path,
                         org.ow2.petals.registry.api.Resource resource,
                         org.ow2.petals.registry.api.Information information)
                  throws org.ow2.petals.registry.api.exception.RegistryException
Specified by:
put in interface org.ow2.petals.registry.api.RemoteOperations
Throws:
org.ow2.petals.registry.api.exception.RegistryException

doPut

protected boolean doPut(java.lang.String key,
                        org.ow2.petals.registry.api.Resource resource)
                 throws org.ow2.petals.registry.api.exception.RegistryException
Throws:
org.ow2.petals.registry.api.exception.RegistryException

delete

public final boolean delete(java.lang.String path,
                            org.ow2.petals.registry.api.Information information)
                     throws org.ow2.petals.registry.api.exception.RegistryException
Specified by:
delete in interface org.ow2.petals.registry.api.RemoteOperations
Throws:
org.ow2.petals.registry.api.exception.RegistryException

doDelete

protected boolean doDelete(java.lang.String key)
                    throws org.ow2.petals.registry.api.exception.RegistryException
Throws:
org.ow2.petals.registry.api.exception.RegistryException

getAll

public final java.util.List<org.ow2.petals.registry.api.Resource> getAll(java.lang.String path,
                                                                         org.ow2.petals.registry.api.Information information)
                                                                  throws org.ow2.petals.registry.api.exception.RegistryException
Specified by:
getAll in interface org.ow2.petals.registry.api.RemoteOperations
Throws:
org.ow2.petals.registry.api.exception.RegistryException

doGetAll

protected java.util.List<org.ow2.petals.registry.api.Resource> doGetAll(java.lang.String path)
                                                                 throws org.ow2.petals.registry.api.exception.RegistryException
Throws:
org.ow2.petals.registry.api.exception.RegistryException

query

public final java.util.List<org.ow2.petals.registry.api.Resource> query(org.ow2.petals.registry.api.Query query,
                                                                        org.ow2.petals.registry.api.Information information)
                                                                 throws org.ow2.petals.registry.api.exception.RegistryException
Specified by:
query in interface org.ow2.petals.registry.api.RemoteOperations
Throws:
org.ow2.petals.registry.api.exception.RegistryException

doQuery

protected java.util.List<org.ow2.petals.registry.api.Resource> doQuery(org.ow2.petals.registry.api.Query query)
                                                                throws org.ow2.petals.registry.api.exception.RegistryException
Throws:
org.ow2.petals.registry.api.exception.RegistryException

setLifeCycle

protected void setLifeCycle(org.ow2.petals.registry.api.lifecycle.AbstractLifeCycle lifeCycle)
Parameters:
lifeCycle -

getState

public org.ow2.petals.registry.api.lifecycle.LifeCycle.STATE getState()
Specified by:
getState in interface org.ow2.petals.registry.api.lifecycle.LifeCycle

init

public void init(org.ow2.petals.registry.api.context.Context context)
          throws org.ow2.petals.registry.api.exception.LifeCycleException
Specified by:
init in interface org.ow2.petals.registry.api.lifecycle.LifeCycle
Throws:
org.ow2.petals.registry.api.exception.LifeCycleException

isInitialized

public boolean isInitialized()
Specified by:
isInitialized in interface org.ow2.petals.registry.api.lifecycle.LifeCycle

isNotInitialized

public boolean isNotInitialized()
Specified by:
isNotInitialized in interface org.ow2.petals.registry.api.lifecycle.LifeCycle

isRunning

public boolean isRunning()
Specified by:
isRunning in interface org.ow2.petals.registry.api.lifecycle.LifeCycle

isStarted

public boolean isStarted()
Specified by:
isStarted in interface org.ow2.petals.registry.api.lifecycle.LifeCycle

isStopped

public boolean isStopped()
Specified by:
isStopped in interface org.ow2.petals.registry.api.lifecycle.LifeCycle

start

public void start()
           throws org.ow2.petals.registry.api.exception.LifeCycleException
Specified by:
start in interface org.ow2.petals.registry.api.lifecycle.LifeCycle
Throws:
org.ow2.petals.registry.api.exception.LifeCycleException

stop

public void stop()
          throws org.ow2.petals.registry.api.exception.LifeCycleException
Specified by:
stop in interface org.ow2.petals.registry.api.lifecycle.LifeCycle
Throws:
org.ow2.petals.registry.api.exception.LifeCycleException


Copyright © 2005-2011 Petals Link (EBM Websourcing). All Rights Reserved.