Package org.apache.qpid.server.util

Examples of org.apache.qpid.server.util.ConnectionScopedRuntimeException

176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
                return new MessageMetaData(publishBody, chb, arrivalTime);
            }
            catch (IOException e)
            {
                throw new ConnectionScopedRuntimeException(e);
            }
            catch (AMQProtocolVersionException e)
            {
                throw new ConnectionScopedRuntimeException(e);
            }
            catch (AMQFrameDecodingException e)
            {
                throw new ConnectionScopedRuntimeException(e);
            }

        }
View Full Code Here
862
863
864
865
866
867
868
869
870
                }
            }

            if (!_closed)
            {
                throw new ConnectionScopedRuntimeException("Connection " + this + " failed to become closed within " + AWAIT_CLOSED_TIMEOUT + "ms.");
            }
        }
    }
View Full Code Here
187
188
189
190
191
192
193
194
195
196
197
                }
            }
            catch (AmqpErrorException e)
            {
                //TODO
                throw new ConnectionScopedRuntimeException(e);
            }

            Header header = new Header();
            if(oldHeader != null)
            {
View Full Code Here
216
217
218
219
220
221
222
223
224
                os.writeObject(object);
                return bytesOut.toByteArray();
            }
            catch (IOException e)
            {
                throw new ConnectionScopedRuntimeException(e);
            }
        }
    }
View Full Code Here
1978
1979
1980
1981
1982
1983
1984
1985
1986
1987
1988
            QueueEntry node  = getNextAvailableEntry(sub);


            if (_virtualHost.getState() != State.ACTIVE)
            {
                throw new ConnectionScopedRuntimeException("Delivery halted owing to " +
                                                           "virtualhost state " + _virtualHost.getState());
            }

            if (node != null && node.isAvailable())
            {
View Full Code Here
2543
2544
2545
2546
2547
2548
2549
2550
2551
2552
2553
                                                                                        final ServerTransaction txn,
                                                                                        final Action<? super MessageInstance> postEnqueueAction)
    {
        if (_virtualHost.getState() != State.ACTIVE)
        {
            throw new ConnectionScopedRuntimeException("Virtualhost state " + _virtualHost.getState() + " prevents the message from being sent");
        }

        if(!message.isReferenced(this))
        {
            txn.enqueue(this, message, new ServerTransaction.Action()
View Full Code Here
560
561
562
563
564
565
566
567
568
569
570
            case WINDOW:
                _creditManager = new WindowCreditManager(0l,0l);
                break;
            default:
                // this should never happen, as 0-10 is finalised and so the enum should never change
                throw new ConnectionScopedRuntimeException("Unknown message flow mode: " + flowMode);
        }
        _flowMode = flowMode;
        updateState(State.ACTIVE, State.SUSPENDED);

        _creditManager.addStateListener(this);
View Full Code Here
TOP

Related Classes of org.apache.qpid.server.util.ConnectionScopedRuntimeException

  • org.apache.qpid.server.exchange.AbstractExchange
  • org.apache.qpid.server.exchange.TopicExchange
  • org.apache.qpid.server.jmx.mbeans.LoggingManagementMBean
  • org.apache.qpid.server.management.plugin.servlet.rest.AbstractServlet
  • org.apache.qpid.server.management.plugin.servlet.rest.SaslServlet
  • org.apache.qpid.server.message.internal.InternalMessage
  • org.apache.qpid.server.message.internal.InternalMessageMetaData
  • org.apache.qpid.server.message.internal.InternalMessageMetaDataType
  • org.apache.qpid.server.protocol.v0_10.ConsumerTarget_0_10
  • org.apache.qpid.server.protocol.v0_10.MessageConverter_v0_10
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.