Package org.apache.qpid.server.util

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

86
87
88
89
90
91
92
93
            return new InternalMessageMetaData(persistent, bytes, contentSize);

        }
        catch (IOException e)
        {
            throw new ConnectionScopedRuntimeException("Unexpected IO Exception on in memory operation", e);
        }
    }
View Full Code Here
50
51
52
53
54
55
56
57
58
59
60
61
62
            InternalMessageMetaData metaData = (InternalMessageMetaData) is.readObject();
            return metaData;
        }
        catch (IOException e)
        {
            throw new ConnectionScopedRuntimeException("Unexpected IO Exception on operation in memory", e);
        }
        catch (ClassNotFoundException e)
        {
            throw new ConnectionScopedRuntimeException("Unexpected exception when reading meta data, check classpath",e);
        }

    }
View Full Code Here
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
                {
                    list.add(reader.readObject());
                }
                catch (TypedBytesFormatException e)
                {
                    throw new ConnectionScopedRuntimeException(e);
                }
                catch (EOFException e)
                {
                    throw new ConnectionScopedRuntimeException(e);  // TODO - Implement
                }
            }
            return list;
        }
        else
View Full Code Here
185
186
187
188
189
190
191
192
193
194
195
                }
            }
            catch (AmqpErrorException e)
            {
                //TODO
                throw new ConnectionScopedRuntimeException(e);
            }

            Header header = new Header();
            if(oldHeader != null)
            {
View Full Code Here
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
            // We're ok if the exchange already exists
            dlExchange = e.getExistingExchange();
        }
        catch (ReservedExchangeNameException e)
        {
            throw new ConnectionScopedRuntimeException("Attempt to create an alternate exchange for a queue failed",e);
        }
        catch (AMQUnknownExchangeType e)
        {
            throw new ConnectionScopedRuntimeException("Attempt to create an alternate exchange for a queue failed",e);
        }
        catch (UnknownExchangeException e)
        {
            throw new ConnectionScopedRuntimeException("Attempt to create an alternate exchange for a queue failed",e);
        }

        AMQQueue dlQueue = null;

        synchronized(_queueRegistry)
View Full Code Here
237
238
239
240
241
242
243
244
245
                os.writeObject(object);
                return bytesOut.toByteArray();
            }
            catch (IOException e)
            {
                throw new ConnectionScopedRuntimeException(e);
            }
        }
    }
View Full Code Here
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
                {
                    list.add(reader.readObject());
                }
                catch (TypedBytesFormatException e)
                {
                    throw new ConnectionScopedRuntimeException(e);
                }
                catch (EOFException e)
                {
                    throw new ConnectionScopedRuntimeException(e);
                }
            }
            return list;
        }
        else
View Full Code Here
211
212
213
214
215
216
217
218
219
220
221
                {
                    closeConnection(reason);
                }
                catch (AMQException e)
                {
                    throw new ConnectionScopedRuntimeException(e);
                }
            }
        }, getVirtualHost());

        Subject.doAs(_subject, new PrivilegedAction<Object>()
View Full Code Here
133
134
135
136
137
138
139
140
141
142
        }
        catch (IOException e)
        {
            // This shouldn't happen as we are not actually using anything that can throw an IO Exception
            throw new ConnectionScopedRuntimeException(e);
        }

        return dest.position()-oldPosition;
    }
View Full Code Here
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
                        };
                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
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.