Examples of com.hazelcast.core.HazelcastInstanceNotActiveException

com.hazelcast.core.HazelcastInstanceNotActiveException
Thrown when HazelcastInstance is not active during an invocation.

            final SerializerAdapter serializer = serializerFor(obj.getClass());
            if (serializer == null) {
                if (active) {
                    throw new HazelcastSerializationException("There is no suitable serializer for " + obj.getClass());
                }
                throw new HazelcastInstanceNotActiveException();
            }
            out.writeInt(serializer.getTypeId());
            serializer.write(out, obj);
        } catch (Throwable e) {
            throw handleException(e);

View Full Code Here

            final SerializerAdapter serializer = serializerFor(typeId);
            if (serializer == null) {
                if (active) {
                    throw new HazelcastSerializationException("There is no suitable de-serializer for type " + typeId);
                }
                throw new HazelcastInstanceNotActiveException();
            }
            Object obj = serializer.read(in);
            if (managedContext != null) {
                obj = managedContext.initialize(obj);
            }

View Full Code Here


    void shutdown() {
        logger.finest("Stopping tasks...");
        expirationTask.cancel(true);
        expirationService.shutdown();
        final Object response = new HazelcastInstanceNotActiveException();
        final Address thisAddress = nodeEngine.getThisAddress();
        for (Queue<WaitingOp> q : mapWaitingOps.values()) {
            for (WaitingOp waitingOp : q) {
                if (waitingOp.isValid()) {
                    final Operation op = waitingOp.getOperation();

View Full Code Here

        return cacheService;
    }


    protected NodeEngine getNodeEngine() {
        if (nodeEngine == null || !nodeEngine.isActive()) {
            throw new HazelcastInstanceNotActiveException();
        }
        return nodeEngine;
    }

View Full Code Here

            throwNotActiveException();
        }
    }


    protected void throwNotActiveException() {
        throw new HazelcastInstanceNotActiveException();
    }

View Full Code Here

     * @throws HazelcastInstanceNotActiveException if object is destroyed or HazelcastInstance shutdown.
     */
    public final S getService() {
        final S s = service;
        if (s == null) {
            throw new HazelcastInstanceNotActiveException();
        }
        return s;
    }

View Full Code Here

            return -1;
        }


        private void processRequest(ClientEndpointImpl endpoint, ClientRequest request) throws Exception {
            if (!node.joined()) {
                throw new HazelcastInstanceNotActiveException("Hazelcast instance is not ready yet!");
            }


            request.setEndpoint(endpoint);
            initService(request);
            request.setClientEngine(ClientEngineImpl.this);

View Full Code Here

            Object service = nodeEngine.getService(serviceName);
            if (service == null) {
                if (nodeEngine.isActive()) {
                    throw new IllegalArgumentException("No service registered with name: " + serviceName);
                }
                throw new HazelcastInstanceNotActiveException();
            }
            request.setService(service);
        }

View Full Code Here

            if (nodeEngine.isActive()) {
                String message = "Client " + endpoint + " must authenticate before any operation.";
                logger.severe(message);
                exception = new AuthenticationException(message);
            } else {
                exception = new HazelcastInstanceNotActiveException();
            }
            endpoint.sendResponse(exception, request.getCallId());
            endpointManager.removeEndpoint(endpoint);
        }

View Full Code Here

            this.service = nodeEngine.getService(serviceName);
            if (service == null) {
                if (nodeEngine.isActive()) {
                    throw new IllegalArgumentException("Unknown service: " + serviceName);
                } else {
                    throw new HazelcastInstanceNotActiveException();
                }
            }
        }

View Full Code Here

0 1 2 3 4 5 6

TOP

Related Classes of com.hazelcast.core.HazelcastInstanceNotActiveException

com.hazelcast.cache.impl.AbstractCacheProxyBase

com.hazelcast.client.ClientEngineImpl$ClientPacketProcessor

com.hazelcast.client.HazelcastClientProxy

com.hazelcast.client.impl.ClientEngineImpl$ClientPacketProcessor

com.hazelcast.client.impl.HazelcastClientProxy

com.hazelcast.cluster.ClusterServiceImpl

com.hazelcast.cluster.impl.ClusterServiceImpl

com.hazelcast.instance.HazelcastInstanceProxy

com.hazelcast.instance.TerminatedLifecycleService

com.hazelcast.nio.serialization.SerializationServiceImpl

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.