private void validateProcessReference(List<String> mqProcessList,
            Map<String, String> connectionProcessMap) throws RabbitmqCommunicateException
    {
        //RabbitMQプロセス一覧が未設定の場合、例外を出力する。
        if (mqProcessList == null || mqProcessList.size() == 0)
        {
            String message = "ProcessList is not defined.";
            throw new RabbitmqCommunicateException(message);
        }

        // 呼出元別、接続先RabbitMQプロセスの定義マップが未設定の場合、確認を行わない。
        if (connectionProcessMap == null || connectionProcessMap.size() == 0)
        {
            return;
        }

        Set<String> processSet = new HashSet<String>(mqProcessList);
        Set<String> connectionProcessSet = new HashSet<String>(connectionProcessMap.values());

        if (processSet.containsAll(connectionProcessSet) == false)
        {
            @SuppressWarnings("unchecked")
            Set<String> nonContainedProcessSet = new HashSet<String>(CollectionUtils.subtract(
                    connectionProcessSet, processSet));
            String messageFmt = "Connection process is illegal. NonContainedProcessSet={0}";
            String message = MessageFormat.format(messageFmt, nonContainedProcessSet.toString());
            throw new RabbitmqCommunicateException(message);
        }
    }
private void validateProcessReference ( List < String > mqProcessList , Map < String , String > connectionProcessMap ) throws RabbitmqCommunicateException { if ( mqProcessList == null || mqProcessList . size ( ) == 0 ) { String message = "ProcessList is not defined." ; throw new RabbitmqCommunicateException ( message ) ; } if ( connectionProcessMap == null || connectionProcessMap . size ( ) == 0 ) { return ; } Set < String > processSet = new HashSet < String > ( mqProcessList ) ; Set < String > connectionProcessSet = new HashSet < String > ( connectionProcessMap . values ( ) ) ; if ( processSet . containsAll ( connectionProcessSet ) == false ) { @ SuppressWarnings ( "unchecked" ) Set < String > nonContainedProcessSet = new HashSet < String > ( CollectionUtils . subtract ( connectionProcessSet , processSet ) ) ; String messageFmt = "Connection process is illegal. NonContainedProcessSet={0}" ; String message = MessageFormat . format ( messageFmt , nonContainedProcessSet . toString ( ) ) ; throw new RabbitmqCommunicateException ( message ) ; } }
接続先RabbitMQプロセスがRabbitMQプロセス一覧に定義されていることを確認する。

@param mqProcessList RabbitMQプロセス一覧
@param connectionProcessMap 呼出元別、接続先RabbitMQプロセスの定義マップ
@throws RabbitmqCommunicateException 接続先RabbitMQプロセスがRabbitMQプロセス一覧に定義されていない場合