public class RabbitConnectionFactoryBean extends AbstractFactoryBean<com.rabbitmq.client.ConnectionFactory>
sslPropertiesLocation が null でない場合、デフォルトの実装は、提供されたプロパティを使用して PKCS12 キーストアと JKS トラストストアをロードし、デフォルトでアルゴリズム SunX509 を使用してキーとトラストマネージャーファクトリを初期化します。これらは、sslAlgorithm (デフォルト TLSv1.1) を使用して SSLContextSE を初期化するために使用されます。createSSLContext() をオーバーライドして、コンテキストを作成および / またはさらに変更します。
setUpSSL() をオーバーライドして、SSL の設定を完全に制御します。
| 修飾子と型 | フィールドと説明 |
|---|---|
protected com.rabbitmq.client.ConnectionFactory | connectionFactory |
loggerOBJECT_TYPE_ATTRIBUTE| コンストラクターと説明 |
|---|
RabbitConnectionFactoryBean() |
| 修飾子と型 | メソッドと説明 |
|---|---|
void | afterPropertiesSet() |
protected KeyManagerSE[] | configureKeyManagers() |
protected TrustManagerSE[] | configureTrustManagers() |
protected com.rabbitmq.client.ConnectionFactory | createInstance() |
protected SSLContextSE | createSSLContext() このメソッドをオーバーライドして、 ConnectionFactory で使用される SSLContextSE を作成および / または構成します。 |
protected StringSE | getKeyStore() |
protected StringSE | getKeyStoreAlgorithm() |
protected StringSE | getKeyStorePassphrase() |
protected Resource | getKeyStoreResource() |
protected StringSE | getKeyStoreType() キーストア型を取得します。これは、 setSslPropertiesLocation(Resource) または setKeyStoreType(java.lang.String) によってオーバーライドされない場合、デフォルトで PKCS12 になります。 |
ClassSE<?> | getObjectType() |
com.rabbitmq.client.ConnectionFactory | getRabbitConnectionFactory() 接続ファクトリにアクセスして、このファクトリ Bean でサポートされていないその他のプロパティを設定します。 |
protected SecureRandomSE | getSecureRandom() |
protected StringSE | getSslAlgorithm() |
protected Resource | getSslPropertiesLocation() |
protected StringSE | getTrustStore() |
protected StringSE | getTrustStoreAlgorithm() |
protected StringSE | getTrustStorePassphrase() |
protected Resource | getTrustStoreResource() |
protected StringSE | getTrustStoreType() トラストストア型を取得します。これは、 setSslPropertiesLocation(Resource) または setTrustStoreType(java.lang.String) によってオーバーライドされない場合、デフォルトで JKS になります。 |
boolean | isSkipServerCertificateValidation() サーバー側の証明書を検証する必要があるかどうか。 |
protected boolean | isUseSSL() |
void | setAutomaticRecoveryEnabled(boolean automaticRecoveryEnabled)amqp-client 自動リカバリを有効にするには、true に設定します。 |
void | setChannelRpcTimeout(int channelRpcTimeout) |
void | setClientProperties(MapSE<StringSE, ObjectSE> clientProperties) カスタムクライアントプロパティを追加します。 |
void | setConnectionTimeout(int connectionTimeout) |
void | setEnableHostnameVerification(boolean enable)TLS 接続のサーバーホスト名検証を有効にします。 |
void | setExceptionHandler(com.rabbitmq.client.ExceptionHandler exceptionHandler) |
void | setHost(StringSE host) |
void | setKeyStore(StringSE keyStore) キーストアリソースを設定します (例: |
void | setKeyStoreAlgorithm(StringSE keyStoreAlgorithm) キーストアの作成時に使用するアルゴリズムを設定します。デフォルトは SunX509 です。 |
void | setKeyStorePassphrase(StringSE keyStorePassphrase) キーストアのパスフレーズを設定します - setSslPropertiesLocation(Resource) のプロパティを上書きします。 |
void | setKeyStoreResource(Resource keyStoreResource) キーストアを指す Resource を設定します。 |
void | setKeyStoreType(StringSE keyStoreType) キーストア型を設定します - setSslPropertiesLocation(Resource) のプロパティをオーバーライドします。 |
void | setMetricsCollector(com.rabbitmq.client.MetricsCollector metricsCollector) |
void | setNioParams(com.rabbitmq.client.impl.nio.NioParams nioParams) |
void | setPassword(StringSE password) |
void | setPort(int port) |
void | setRequestedChannelMax(int requestedChannelMax) |
void | setRequestedFrameMax(int requestedFrameMax) |
void | setRequestedHeartbeat(int requestedHeartbeat) |
void | setSaslConfig(com.rabbitmq.client.SaslConfig saslConfig) |
void | setSecureRandom(SecureRandomSE secureRandom)SSLContextSE の初期化時に使用するセキュアランダムを設定します。 |
void | setSharedExecutor(ExecutorServiceSE executor) |
void | setSkipServerCertificateValidation(boolean skipServerCertificateValidation) サーバー側の証明書を検証する必要があるかどうか。 |
void | setSocketConfigurator(com.rabbitmq.client.SocketConfigurator socketConfigurator) |
void | setSocketFactory(SocketFactorySE factory) |
void | setSslAlgorithm(StringSE sslAlgorithm) 使用するアルゴリズムを設定します。デフォルトの TLSv1.1。 |
void | setSslPropertiesLocation(Resource sslPropertiesLocation)setUseSSL(boolean) が true の場合、使用する SSL プロパティ (オプション)。 |
void | setThreadFactory(ThreadFactorySE threadFactory) |
void | setTopologyRecoveryEnabled(boolean topologyRecoveryEnabled)amqp-client トポロジーのリカバリを有効にするには、true に設定します。 |
void | setTrustStore(StringSE trustStore) キーストアリソースを設定します (例: |
void | setTrustStoreAlgorithm(StringSE trustStoreAlgorithm) トラストストアの作成時に使用するアルゴリズムを設定します。デフォルトは SunX509 です。 |
void | setTrustStorePassphrase(StringSE trustStorePassphrase) トラストストアのパスフレーズを設定します - setSslPropertiesLocation(Resource) のプロパティを上書きします。 |
void | setTrustStoreResource(Resource trustStoreResource) トラストストアを指す Resource を設定します。 |
void | setTrustStoreType(StringSE trustStoreType) トラストストア型を設定します - setSslPropertiesLocation(Resource) のプロパティを上書きします。 |
protected void | setUpSSL() このメソッドをオーバーライドして、SSL セットアップを完全に制御します。 |
void | setUri(StringSE uriString) |
void | setUri(URISE uri) |
void | setUseNio(boolean useNio)Java NIO を使用するようにファクトリを構成する必要があるかどうか。 |
void | setUsername(StringSE username) |
void | setUseSSL(boolean useSSL)SSL を使用するようにファクトリを構成する必要があるかどうか。 |
void | setVirtualHost(StringSE virtualHost) |
destroy, destroyInstance, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingletoncloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEpublic boolean isSkipServerCertificateValidation()
public void setSkipServerCertificateValidation(boolean skipServerCertificateValidation)
skipServerCertificateValidation - サーバー側の証明書チェックを上書きするフラグ。true に設定すると、TrustEverythingTrustManager が使用されます。TrustEverythingTrustManagerpublic void setUseSSL(boolean useSSL)
useSSL - SSL を使用する場合は true。protected boolean isUseSSL()
public void setSslAlgorithm(StringSE sslAlgorithm)
sslAlgorithm - アルゴリズム。protected StringSE getSslAlgorithm()
public void setSslPropertiesLocation(Resource sslPropertiesLocation)
setUseSSL(boolean) が true の場合、使用する SSL プロパティ (オプション)。次のプロパティを持つプロパティファイルを参照するリソース:これが提供される場合、そのプロパティ (存在する場合) は、この Bean で明示的に設定されたプロパティをオーバーライドします。
sslPropertiesLocation - Resource を ssl プロパティに protected Resource getSslPropertiesLocation()
protected StringSE getKeyStore()
public void setKeyStore(StringSE keyStore)
setSslPropertiesLocation(Resource) のプロパティをオーバーライドします。リソースで setTrustStoreResource(Resource) が呼び出された場合は無視されます。keyStore - キーストアリソース。protected Resource getKeyStoreResource()
public void setKeyStoreResource(Resource keyStoreResource)
keyStoreResource - リソース。protected StringSE getTrustStore()
public void setTrustStore(StringSE trustStore)
setSslPropertiesLocation(Resource) のプロパティをオーバーライドします。リソースで setTrustStoreResource(Resource) が呼び出された場合は無視されます。trustStore - トラストストアリソース。protected Resource getTrustStoreResource()
public void setTrustStoreResource(Resource trustStoreResource)
trustStoreResource - リソース。protected StringSE getKeyStorePassphrase()
public void setKeyStorePassphrase(StringSE keyStorePassphrase)
setSslPropertiesLocation(Resource) のプロパティを上書きします。keyStorePassphrase - キーストアのパスフレーズ。protected StringSE getTrustStorePassphrase()
public void setTrustStorePassphrase(StringSE trustStorePassphrase)
setSslPropertiesLocation(Resource) のプロパティを上書きします。trustStorePassphrase - トラストストアのパスフレーズ。protected StringSE getKeyStoreType()
setSslPropertiesLocation(Resource) または setKeyStoreType(java.lang.String) によってオーバーライドされない場合、デフォルトで PKCS12 になります。public void setKeyStoreType(StringSE keyStoreType)
setSslPropertiesLocation(Resource) のプロパティをオーバーライドします。keyStoreType - キーストア型。KeyStore.getInstance(String)SEprotected StringSE getTrustStoreType()
setSslPropertiesLocation(Resource) または setTrustStoreType(java.lang.String) によってオーバーライドされない場合、デフォルトで JKS になります。public void setTrustStoreType(StringSE trustStoreType)
setSslPropertiesLocation(Resource) のプロパティを上書きします。trustStoreType - トラストストアの型。KeyStore.getInstance(String)SEprotected SecureRandomSE getSecureRandom()
public void setSecureRandom(SecureRandomSE secureRandom)
SSLContextSE の初期化時に使用するセキュアランダムを設定します。デフォルトは null です。この場合、デフォルトの実装が使用されます。secureRandom - 安全なランダム。SSLContext.init(KeyManager[], TrustManager[], SecureRandom)SEpublic void setHost(StringSE host)
host - ザホスト。ConnectionFactory.setHost(java.lang.String)public void setPort(int port)
port - ポート。ConnectionFactory.setPort(int)public void setUsername(StringSE username)
username - ユーザー名。ConnectionFactory.setUsername(java.lang.String)public void setPassword(StringSE password)
password - パスワード。ConnectionFactory.setPassword(java.lang.String)public void setVirtualHost(StringSE virtualHost)
virtualHost - 仮想ホスト。ConnectionFactory.setVirtualHost(java.lang.String)public void setUri(URISE uri)
uri - uri。ConnectionFactory.setUri(java.net.URI)public void setUri(StringSE uriString)
uriString - uri。ConnectionFactory.setUri(java.lang.String)public void setRequestedChannelMax(int requestedChannelMax)
requestedChannelMax - リクエストされた最大チャネル。ConnectionFactory.setRequestedChannelMax(int)public void setRequestedFrameMax(int requestedFrameMax)
requestedFrameMax - リクエストされた最大フレーム。ConnectionFactory.setRequestedFrameMax(int)public void setConnectionTimeout(int connectionTimeout)
connectionTimeout - 接続タイムアウト。ConnectionFactory.setConnectionTimeout(int)public void setRequestedHeartbeat(int requestedHeartbeat)
requestedHeartbeat - リクエストされたハートビート。ConnectionFactory.setRequestedHeartbeat(int)public void setClientProperties(MapSE<StringSE,ObjectSE> clientProperties)
clientProperties - クライアントプロパティ。ConnectionFactory.setClientProperties(java.util.Map)public void setSaslConfig(com.rabbitmq.client.SaslConfig saslConfig)
saslConfig - sasl 設定。ConnectionFactory.setSaslConfig(com.rabbitmq.client.SaslConfig)public void setSocketFactory(SocketFactorySE factory)
factory - ソケットファクトリ。ConnectionFactory.setSocketFactory(javax.net.SocketFactory)public void setSocketConfigurator(com.rabbitmq.client.SocketConfigurator socketConfigurator)
socketConfigurator - ソケットコンフィギュレータ。ConnectionFactory.setSocketConfigurator(com.rabbitmq.client.SocketConfigurator)public void setSharedExecutor(ExecutorServiceSE executor)
executor - エグゼキュータサービス ConnectionFactory.setSharedExecutor(java.util.concurrent.ExecutorService)public void setThreadFactory(ThreadFactorySE threadFactory)
threadFactory - スレッドファクトリ。ConnectionFactory.setThreadFactory(java.util.concurrent.ThreadFactory)public void setExceptionHandler(com.rabbitmq.client.ExceptionHandler exceptionHandler)
exceptionHandler - 例外ハンドラー。ConnectionFactory.setExceptionHandler(com.rabbitmq.client.ExceptionHandler)public void setUseNio(boolean useNio)
useNio - Java NIO を使用する場合は true、ブロッキング IO を使用する場合は falseConnectionFactory.useNio()public void setNioParams(com.rabbitmq.client.impl.nio.NioParams nioParams)
nioParams - NIO パラメーター ConnectionFactory.setNioParams(com.rabbitmq.client.impl.nio.NioParams)public void setMetricsCollector(com.rabbitmq.client.MetricsCollector metricsCollector)
metricsCollector - メトリクスコレクターインスタンス ConnectionFactory.setMetricsCollector(MetricsCollector)public void setAutomaticRecoveryEnabled(boolean automaticRecoveryEnabled)
automaticRecoveryEnabled - 有効にする場合は true。public void setTopologyRecoveryEnabled(boolean topologyRecoveryEnabled)
topologyRecoveryEnabled - 有効にする場合は true。public void setChannelRpcTimeout(int channelRpcTimeout)
channelRpcTimeout - チャネルでの RPC 呼び出しの継続タイムアウト ConnectionFactory.setChannelRpcTimeout(int)public void setEnableHostnameVerification(boolean enable)
これにより、使用される IO モード (ブロッキングまたはノンブロッキング IO) に関係なく、ホスト名の検証が可能になります。
これは通常、useSslProtocol メソッドの 1 つを使用して SSLContextSE を設定した後に呼び出すことができます。amqp-client 5.4.0 以降が必要です。
enable - 無効にする場合は false。ConnectionFactory.enableHostnameVerification()protected StringSE getKeyStoreAlgorithm()
public void setKeyStoreAlgorithm(StringSE keyStoreAlgorithm)
SunX509 です。keyStoreAlgorithm - アルゴリズム。protected StringSE getTrustStoreAlgorithm()
public void setTrustStoreAlgorithm(StringSE trustStoreAlgorithm)
SunX509 です。trustStoreAlgorithm - アルゴリズム。public com.rabbitmq.client.ConnectionFactory getRabbitConnectionFactory()
public void afterPropertiesSet()
InitializingBean 内の afterPropertiesSet AbstractFactoryBean<com.rabbitmq.client.ConnectionFactory> の afterPropertiesSet public ClassSE<?> getObjectType()
FactoryBean<com.rabbitmq.client.ConnectionFactory> 内の getObjectType AbstractFactoryBean<com.rabbitmq.client.ConnectionFactory> の getObjectType protected com.rabbitmq.client.ConnectionFactory createInstance()
AbstractFactoryBean<com.rabbitmq.client.ConnectionFactory> の createInstance protected void setUpSSL()
@Nullable protected KeyManagerSE[] configureKeyManagers() throws KeyStoreExceptionSE, IOExceptionSE, NoSuchAlgorithmExceptionSE, CertificateExceptionSE, UnrecoverableKeyExceptionSE
@Nullable protected TrustManagerSE[] configureTrustManagers() throws KeyStoreExceptionSE, IOExceptionSE, NoSuchAlgorithmExceptionSE, CertificateExceptionSE
protected SSLContextSE createSSLContext() throws NoSuchAlgorithmExceptionSE
ConnectionFactory で使用される SSLContextSE を作成および / または構成します。SSLContextSE。NoSuchAlgorithmExceptionSE - アルゴリズムが利用できない場合。