|
41 | 41 |
|
42 | 42 | public class ConnectionFactory implements Cloneable { |
43 | 43 |
|
44 | | - /** Default Executor threads */ private static final int DEFAULT_NUM_CONSUMER_THREADS = 5; |
45 | | - /** Default user name */ private static final String DEFAULT_USER = "guest"; |
46 | | - /** Default password */ private static final String DEFAULT_PASS = "guest"; |
47 | | - /** Default virtual host */ private static final String DEFAULT_VHOST = "/"; |
| 44 | + /** Default Executor threads */ |
| 45 | + private static final int DEFAULT_NUM_CONSUMER_THREADS = 5; |
| 46 | + /** Default user name */ |
| 47 | + private static final String DEFAULT_USER = "guest"; |
| 48 | + /** Default password */ |
| 49 | + private static final String DEFAULT_PASS = "guest"; |
| 50 | + /** Default virtual host */ |
| 51 | + private static final String DEFAULT_VHOST = "/"; |
48 | 52 | /** Default maximum channel number; |
49 | | - * zero for unlimited */ private static final int DEFAULT_CHANNEL_MAX = 0; |
| 53 | + * zero for unlimited */ |
| 54 | + private static final int DEFAULT_CHANNEL_MAX = 0; |
50 | 55 | /** Default maximum frame size; |
51 | | - * zero means no limit */ private static final int DEFAULT_FRAME_MAX = 0; |
| 56 | + * zero means no limit */ |
| 57 | + private static final int DEFAULT_FRAME_MAX = 0; |
52 | 58 | /** Default heart-beat interval; |
53 | | - * zero means no heart-beats */ private static final int DEFAULT_HEARTBEAT = 0; |
54 | | - /** The default host */ private static final String DEFAULT_HOST = "localhost"; |
55 | | - /** 'Use the default port' port */ private static final int USE_DEFAULT_PORT = -1; |
56 | | - /** The default non-ssl port */ private static final int DEFAULT_AMQP_PORT = AMQP.PROTOCOL.PORT; |
57 | | - /** The default ssl port */ private static final int DEFAULT_AMQP_OVER_SSL_PORT = 5671; |
| 59 | + * zero means no heart-beats */ |
| 60 | + private static final int DEFAULT_HEARTBEAT = 0; |
| 61 | + /** The default host */ |
| 62 | + private static final String DEFAULT_HOST = "localhost"; |
| 63 | + /** 'Use the default port' port */ |
| 64 | + private static final int USE_DEFAULT_PORT = -1; |
| 65 | + /** The default non-ssl port */ |
| 66 | + private static final int DEFAULT_AMQP_PORT = AMQP.PROTOCOL.PORT; |
| 67 | + /** The default ssl port */ |
| 68 | + private static final int DEFAULT_AMQP_OVER_SSL_PORT = 5671; |
58 | 69 | /** The default connection timeout; |
59 | | - * zero means wait indefinitely */ private static final int DEFAULT_CONNECTION_TIMEOUT = 0; |
60 | | - /** The default SSL protocol */ private static final String DEFAULT_SSL_PROTOCOL = "SSLv3"; |
| 70 | + * zero means wait indefinitely */ |
| 71 | + private static final int DEFAULT_CONNECTION_TIMEOUT = 0; |
| 72 | + /** The default SSL protocol */ |
| 73 | + private static final String DEFAULT_SSL_PROTOCOL = "SSLv3"; |
61 | 74 |
|
62 | 75 | private int numConsumerThreads = DEFAULT_NUM_CONSUMER_THREADS; |
63 | 76 | private String username = DEFAULT_USER; |
|
0 commit comments