Examples of org.apache.axis2.context.MessageContext.activate()

Class org.apache.axis2.context.MessageContext

Examples of org.apache.axis2.context.MessageContext.activate()

org.apache.axis2.context.MessageContext.activate()
This method checks to see if additional work needs to be done in order to complete the object reconstitution. Some parts of the object restored from the readExternal() cannot be completed until we have a configurationContext from the active engine. The configurationContext is used to help this object to plug back into the engine's configuration and deployment objects. @param cc The configuration context object representing the active configuration

                    // stream connected to the file
                    objectInputStream = new ObjectInputStream(inStream);


                    System.out.println("Worker thread restoring message context from file");
                    reconstitutedMessageContext = (MessageContext)objectInputStream.readObject();
                    reconstitutedMessageContext.activate(configurationContext);
                } else if (serializedMessageContext != null) {
                    // use the byte array
                    objectInputStream = new ObjectInputStream(
                            new ByteArrayInputStream(serializedMessageContext));

View Full Code Here

                    objectInputStream = new ObjectInputStream(
                            new ByteArrayInputStream(serializedMessageContext));


                    System.out.println("Worker thread restoring message context from byte array");
                    reconstitutedMessageContext = (MessageContext)objectInputStream.readObject();
                    reconstitutedMessageContext.activate(configurationContext);
                } else if (msgContext != null) {
                    System.out.println("Worker thread using message context");
                    reconstitutedMessageContext = msgContext;
                }

View Full Code Here

                System.out.println("MessageSaveAndRestoreWithMTOMTest:Resuming processing");
                ObjectInputStream objectInputStream =
                        new ObjectInputStream(new ByteArrayInputStream(serializedMessageContext));
                MessageContext reconstitutedMessageContext =
                        (MessageContext)objectInputStream.readObject();
                reconstitutedMessageContext.activate(configurationContext);
                axisEngine.resume(reconstitutedMessageContext);
            }
            catch (Exception e) {
                e.printStackTrace();
                fail("An error occurred in the worker thread");

View Full Code Here

                    // stream connected to the file
                    objectInputStream = new ObjectInputStream(inStream);


                    System.out.println("Worker thread restoring message context from file");
                    reconstitutedMessageContext = (MessageContext)objectInputStream.readObject();
                    reconstitutedMessageContext.activate(configurationContext);
                } else if (serializedMessageContext != null) {
                    // use the byte array
                    objectInputStream = new ObjectInputStream(
                            new ByteArrayInputStream(serializedMessageContext));

View Full Code Here

                    objectInputStream = new ObjectInputStream(
                            new ByteArrayInputStream(serializedMessageContext));


                    System.out.println("Worker thread restoring message context from byte array");
                    reconstitutedMessageContext = (MessageContext)objectInputStream.readObject();
                    reconstitutedMessageContext.activate(configurationContext);
                } else if (msgContext != null) {
                    System.out.println("Worker thread using message context");
                    reconstitutedMessageContext = msgContext;
                }

View Full Code Here

      ResultSet rs = stmt.executeQuery("select * from wsrm_msgctx where ctx_key='" +
          key + "'");
      rs.next();
      MessageContext msgCtx = new MessageContext();
      msgCtx.readExternal(new ObjectInputStream(rs.getBinaryStream("ctx")));
      msgCtx.activate(configContext);
      msgCtx.setProperty(Sandesha2Constants.POST_FAILURE_MESSAGE, Sandesha2Constants.VALUE_TRUE);
      rs.close();
      stmt.close();
      log.debug("RetrieveMessageContext get from DB");
      return msgCtx;

View Full Code Here

            entry.message = null;
          } else {
            ByteArrayInputStream stream = new ByteArrayInputStream(entry.data);
            ObjectInputStream is = new ObjectInputStream(stream);
            messageContext = (MessageContext) is.readObject();
            messageContext.activate(entry.context);
  
            OperationContext opCtx = messageContext.getOperationContext();
            if(opCtx != null) {
              MessageContext inMsgCtx = opCtx.getMessageContext(WSDLConstants.MESSAGE_LABEL_IN_VALUE);
              if(inMsgCtx != null) {

View Full Code Here

                System.out.println("MessageSaveAndRestoreWithMTOMTest:Resuming processing");
                ObjectInputStream objectInputStream =
                        new ObjectInputStream(new ByteArrayInputStream(serializedMessageContext));
                MessageContext reconstitutedMessageContext =
                        (MessageContext)objectInputStream.readObject();
                reconstitutedMessageContext.activate(configurationContext);
                axisEngine.resume(reconstitutedMessageContext);
            }
            catch (Exception e) {
                e.printStackTrace();
                fail("An error occurred in the worker thread");

View Full Code Here

                System.out.println("MessageSaveAndRestoreTest:Resuming processing");
                ObjectInputStream objectInputStream =
                        new ObjectInputStream(new ByteArrayInputStream(serializedMessageContext));
                MessageContext reconstitutedMessageContext =
                        (MessageContext)objectInputStream.readObject();
                reconstitutedMessageContext.activate(configurationContext);
                AxisEngine.resume(reconstitutedMessageContext);
            }
            catch (Exception e) {
                e.printStackTrace();
                fail("An error occurred in the worker thread");

View Full Code Here

                    // stream connected to the file
                    objectInputStream = new ObjectInputStream(inStream);


                    System.out.println("Worker thread restoring message context from file");
                    reconstitutedMessageContext = (MessageContext)objectInputStream.readObject();
                    reconstitutedMessageContext.activate(configurationContext);
                } else if (serializedMessageContext != null) {
                    // use the byte array
                    objectInputStream = new ObjectInputStream(
                            new ByteArrayInputStream(serializedMessageContext));

View Full Code Here

0 1 2 3 4 5 6

TOP

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.