Oleg Zhurakousky 812da19cad NIFI-614 Added initial support for new style JMS
NIFI-614 finalized JMSConnectionFactoryProvider ControllerService

NIFI-614 finalized implementation of both Processors and ControllerService

NIFI-614 added initial documentation

NIFI-614 addressed PR comment with unused import and squashed

NIFI-614 added @OnDisabled method

NIFI-614 changed POMs to 0.6

NIFI-614 removed local .gitignore

NIFI-614 added support for parsing Tibco URL

NIFI-614 removed setting of jms message id

NIFI-614 addressed PR comments, fixed tests

NIFI-614 addressed latest PR comments

NIFI-614 second round of PR comments addressed

NIFI-614 3rd round of PR comments addressed

NIFI-614 finalizing on PR comments

NIFI-614 more PR comments

This closes #222

Signed-off-by: jpercivall <joepercivall@yahoo.com>
2016-03-15 15:48:03 -04:00

112 lines
2.7 KiB
Java

/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.nifi.jms.testcflib;
import static org.mockito.Mockito.mock;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSContext;
import javax.jms.JMSException;
public class TestConnectionFactory implements ConnectionFactory {
private String user;
private String password;
private String foo;
private int bar;
private String host;
private int port;
@Override
public Connection createConnection() throws JMSException {
return mock(Connection.class);
}
@Override
public Connection createConnection(String userName, String password) throws JMSException {
this.user = user;
this.password = password;
return mock(Connection.class);
}
@Override
public JMSContext createContext() {
return mock(JMSContext.class);
}
@Override
public JMSContext createContext(String userName, String password) {
this.user = user;
this.password = password;
return mock(JMSContext.class);
}
@Override
public JMSContext createContext(String userName, String password, int sessionMode) {
this.user = user;
this.password = password;
return mock(JMSContext.class);
}
@Override
public JMSContext createContext(int sessionMode) {
return mock(JMSContext.class);
}
public void setFoo(String foo) {
this.foo = foo;
}
public void setBar(int bar) {
this.bar = bar;
}
public String getUser() {
return user;
}
public String getPassword() {
return password;
}
public String getFoo() {
return foo;
}
public int getBar() {
return bar;
}
public String getHost() {
return host;
}
public void setHost(String host) {
this.host = host;
}
public int getPort() {
return port;
}
public void setPort(int port) {
this.port = port;
}
}