本文整理汇总了C#中IConnectionFactory类的典型用法代码示例。如果您正苦于以下问题:C# IConnectionFactory类的具体用法?C# IConnectionFactory怎么用?C# IConnectionFactory使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
IConnectionFactory类属于命名空间,在下文中一共展示了IConnectionFactory类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的C#代码示例。
示例1: RabbitResourceHolder
public RabbitResourceHolder(IConnectionFactory connectionFactory, IConnection connection, IModel channel)
{
this.connectionFactory = connectionFactory;
AddConnection(connection);
AddChannel(channel);
this.frozen = true;
}
开发者ID:moprise,项目名称:spring-net-amqp,代码行数:7,代码来源:RabbitResourceHolder.cs
示例2: SharedConnectionPoolFactory
public SharedConnectionPoolFactory(
IConnectionFactory connectionFactory,
ConnectionPoolSettings connectionPoolSettings)
{
_connectionFactory = Ensure.IsNotNull(connectionFactory, "connectionFactory");
_connectionPoolSettings = Ensure.IsNotNull(connectionPoolSettings, "connectionPoolSettings");
}
开发者ID:Nakro,项目名称:mongo-csharp-driver,代码行数:7,代码来源:SharedConnectionPoolFactory.cs
示例3: PersistentConnection
public PersistentConnection(IConnectionFactory connectionFactory, IEasyNetQLogger logger)
{
this.connectionFactory = connectionFactory;
this.logger = logger;
TryToConnect(null);
}
开发者ID:negy,项目名称:EasyNetQ,代码行数:7,代码来源:PersistentConnection.cs
示例4: Db
/// <summary>
/// Instantiate Db with connectionString and a custom IConnectionFactory
/// </summary>
/// <param name="connectionString">the connection string</param>
/// <param name="config"></param>
/// <param name="connectionFactory">the connection factory</param>
internal Db(string connectionString, DbConfig config, IConnectionFactory connectionFactory = null)
{
_connectionString = connectionString;
_connectionFactory = connectionFactory ?? new AdoNetProviderFactory(config.ProviderName);
_connection = new Lazy<IDbConnection>(CreateConnection);
Config = config;
}
开发者ID:jhgbrt,项目名称:yadal,代码行数:13,代码来源:Db.cs
示例5: Setup
public void Setup()
{
factory = A.Fake<IConnectionFactory>();
fakeHttp = A.Fake<ISimpleHttpGetRequest>();
fakeWebSocket = A.Fake<IWebSocket>();
heartBeatSignaler = A.Fake<IHeartBeatSignaler>();
A.CallTo(() => factory.CreateHttpRequest(A<string>._)).Returns(fakeHttp);
A.CallTo(() => fakeHttp.Execute()).ReturnsLazily(() => handshakeResponse);
A.CallTo(() => factory.CreateWebSocket(A<string>._)).Returns(fakeWebSocket);
A.CallTo(() => fakeWebSocket.Connected).ReturnsLazily(() => isConnected);
A.CallTo(() => fakeWebSocket.Open()).Invokes(() =>
{
isConnected = true;
fakeWebSocket.Opened += Raise.With(fakeWebSocket, EventArgs.Empty).Now;
});
A.CallTo(() => fakeWebSocket.Close()).Invokes(() =>
{
isConnected = false;
fakeWebSocket.Closed += Raise.With(fakeWebSocket, EventArgs.Empty).Now;
});
io = new SocketIOClient(factory, heartBeatSignaler);
socket = io.Connect("http://localhost:3000");
}
开发者ID:hjhome2000,项目名称:socket.io-csharp-client,代码行数:28,代码来源:Client.cs
示例6: InheritedSqlPersistenceEngine
public InheritedSqlPersistenceEngine(
IConnectionFactory connectionFactory,
ISqlDialect dialect,
ISerialize serializer,
TransactionScopeOption scopeOption, int pageSize)
: base(connectionFactory, dialect, serializer, scopeOption, pageSize)
{}
开发者ID:hawkins6423,项目名称:NEventStore,代码行数:7,代码来源:SqlPersistenceEngineTests.cs
示例7: LinearBlockIdGenerator
public LinearBlockIdGenerator(IConnectionFactory connectionFactory, int range, string dimension, string tablePrefix)
{
_connectionFactory = connectionFactory;
_range = range;
_tablePrefix = tablePrefix;
_dimension = dimension;
}
开发者ID:SmartFire,项目名称:yessql,代码行数:7,代码来源:LinearBlockIdGenerator.cs
示例8: CreateMocks
private void CreateMocks()
{
mockConnectionFactory = (IConnectionFactory) mocks.CreateMock(typeof (IConnectionFactory));
mockConnection = (IConnection) mocks.CreateMock(typeof (IConnection));
mockSession = (ISession) mocks.CreateMock(typeof (ISession));
TIBCO.EMS.Queue queue = new TIBCO.EMS.Queue("test"); //(Queue) mocks.CreateMock(typeof (Queue));
Expect.Call(mockConnectionFactory.CreateConnection()).Return(mockConnection).Repeat.Once();
if (UseTransactedTemplate)
{
Expect.Call(mockConnection.CreateSession(true, Session.SESSION_TRANSACTED)).Return(mockSession).Repeat.
Once();
}
else
{
Expect.Call(mockConnection.CreateSession(false, Session.AUTO_ACKNOWLEDGE)).Return(mockSession).
Repeat.
Once();
}
Expect.Call(mockSession.Transacted).Return(true);
mockDestinationResolver =
(IDestinationResolver) mocks.CreateMock(typeof (IDestinationResolver));
mockDestinationResolver.ResolveDestinationName(mockSession, "testDestination", false);
LastCall.Return(queue).Repeat.Any();
}
开发者ID:fgq841103,项目名称:spring-net,代码行数:27,代码来源:MessageTemplateTests.cs
示例9: PersistentConnection
public PersistentConnection(IConnectionFactory connectionFactory, TimeSpan retryDelay)
{
this.connectionFactory = connectionFactory;
this.retryDelay = retryDelay;
TryToConnect(null);
}
开发者ID:laxmanrapolu,项目名称:NserviceBusDemo,代码行数:7,代码来源:PersistentConnection.cs
示例10: ServerFactory
// constructors
public ServerFactory(ServerSettings settings, IConnectionPoolFactory connectionPoolFactory, IConnectionFactory heartbeatConnectionFactory, IServerListener listener)
{
_settings = Ensure.IsNotNull(settings, "settings");
_connectionPoolFactory = Ensure.IsNotNull(connectionPoolFactory, "connectionPoolFactory");
_heartbeatConnectionFactory = Ensure.IsNotNull(heartbeatConnectionFactory, "heartbeatConnectionFactory");
_listener = listener;
}
开发者ID:Nakro,项目名称:mongo-csharp-driver,代码行数:8,代码来源:ServerFactory.cs
示例11: ConnectionPool
public ConnectionPool( RedisConfiguration configuration, IConnectionFactory connectionFactory )
{
Configuration = configuration;
ConnectionFactory = connectionFactory;
AvailableConnections = new ConcurrentQueue<IConnection>();
ReservedConnections = new ConcurrentDictionary<IConnection, IConnection>();
}
开发者ID:cmgator,项目名称:Symbiote,代码行数:7,代码来源:ConnectionPool.cs
示例12: CustomerAgent
public CustomerAgent(IConnectionFactory ConnectionFactory,
CustomerFactory Factory, CustomerAppService CustomerAppService)
{
this.Factory = Factory;
this.ConnectionFactory = ConnectionFactory;
this.CustomerAppService = CustomerAppService;
}
开发者ID:gcvalderrama,项目名称:netcell,代码行数:7,代码来源:CustomerAgent.cs
示例13: Connection
/// <summary>
/// Initializes a new instance of the <see cref="Connection"/> class.
/// </summary>
/// <param name="factory">The pool.</param>
public Connection(IConnectionFactory factory)
{
if (factory == null)
throw new ArgumentNullException ("factory");
_factory = factory;
}
开发者ID:ningliaoyuan,项目名称:Antaeus,代码行数:11,代码来源:Connection.cs
示例14: ExclusiveConnectionPool
// constructors
public ExclusiveConnectionPool(
ServerId serverId,
EndPoint endPoint,
ConnectionPoolSettings settings,
IConnectionFactory connectionFactory,
IEventSubscriber eventSubscriber)
{
_serverId = Ensure.IsNotNull(serverId, nameof(serverId));
_endPoint = Ensure.IsNotNull(endPoint, nameof(endPoint));
_settings = Ensure.IsNotNull(settings, nameof(settings));
_connectionFactory = Ensure.IsNotNull(connectionFactory, nameof(connectionFactory));
Ensure.IsNotNull(eventSubscriber, nameof(eventSubscriber));
_connectionHolder = new ListConnectionHolder(eventSubscriber);
_poolQueue = new WaitQueue(settings.MaxConnections);
_waitQueue = new SemaphoreSlim(settings.WaitQueueSize);
_maintenanceCancellationTokenSource = new CancellationTokenSource();
_state = new InterlockedInt32(State.Initial);
eventSubscriber.TryGetEventHandler(out _checkingOutConnectionEventHandler);
eventSubscriber.TryGetEventHandler(out _checkedOutConnectionEventHandler);
eventSubscriber.TryGetEventHandler(out _checkingOutConnectionFailedEventHandler);
eventSubscriber.TryGetEventHandler(out _checkingInConnectionEventHandler);
eventSubscriber.TryGetEventHandler(out _checkedInConnectionEventHandler);
eventSubscriber.TryGetEventHandler(out _addingConnectionEventHandler);
eventSubscriber.TryGetEventHandler(out _addedConnectionEventHandler);
eventSubscriber.TryGetEventHandler(out _openingEventHandler);
eventSubscriber.TryGetEventHandler(out _openedEventHandler);
eventSubscriber.TryGetEventHandler(out _closingEventHandler);
eventSubscriber.TryGetEventHandler(out _closedEventHandler);
eventSubscriber.TryGetEventHandler(out _addingConnectionEventHandler);
eventSubscriber.TryGetEventHandler(out _addedConnectionEventHandler);
}
开发者ID:robblovell,项目名称:mongo-csharp-driver,代码行数:34,代码来源:ExclusiveConnectionPool.cs
示例15: ReleaseConnection
/// <summary>
/// Releases the given connection, stopping it (if necessary) and eventually closing it.
/// </summary>
/// <remarks>Checks <see cref="ISmartConnectionFactory.ShouldStop"/>, if available.
/// This is essentially a more sophisticated version of
/// <see cref="NmsUtils.CloseConnection(IConnection, bool)"/>
/// </remarks>
/// <param name="connection">The connection to release. (if this is <code>null</code>, the call will be ignored)</param>
/// <param name="cf">The ConnectionFactory that the Connection was obtained from. (may be <code>null</code>)</param>
/// <param name="started">whether the Connection might have been started by the application.</param>
public static void ReleaseConnection(IConnection connection, IConnectionFactory cf, bool started)
{
if (connection == null)
{
return;
}
if (started && cf is ISmartConnectionFactory && ((ISmartConnectionFactory)cf).ShouldStop(connection))
{
try
{
connection.Stop();
}
catch (Exception ex)
{
LOG.Debug("Could not stop NMS Connection before closing it", ex);
}
}
try
{
connection.Close();
} catch (Exception ex)
{
LOG.Debug("Could not close NMS Connection", ex);
}
}
开发者ID:ouyangyl,项目名称:MySpringNet,代码行数:37,代码来源:ConnectionFactoryUtils.cs
示例16: CreateMocks
private void CreateMocks()
{
mockConnectionFactory = (IConnectionFactory) mocks.CreateMock(typeof (IConnectionFactory));
mockConnection = (IConnection) mocks.CreateMock(typeof (IConnection));
mockSession = (ISession) mocks.CreateMock(typeof (ISession));
IQueue queue = (IQueue) mocks.CreateMock(typeof (IQueue));
Expect.Call(mockConnectionFactory.CreateConnection()).Return(mockConnection).Repeat.Once();
if (UseTransactedTemplate)
{
Expect.Call(mockConnection.CreateSession(AcknowledgementMode.Transactional)).Return(mockSession).Repeat.
Once();
}
else
{
Expect.Call(mockConnection.CreateSession(AcknowledgementMode.AutoAcknowledge)).Return(mockSession).
Repeat.
Once();
}
Expect.Call(mockSession.Transacted).Return(true);
mockDestinationResolver =
(IDestinationResolver) mocks.CreateMock(typeof (IDestinationResolver));
mockDestinationResolver.ResolveDestinationName(mockSession, "testDestination", false);
LastCall.Return(queue).Repeat.Any();
}
开发者ID:fuadm,项目名称:spring-net,代码行数:27,代码来源:MessageTemplateTests.cs
示例17: SequenceFactory
public SequenceFactory(IDocumentSchema schema, IConnectionFactory factory, StoreOptions options, IMartenLogger logger)
{
_schema = schema;
_factory = factory;
_options = options;
_logger = logger;
}
开发者ID:JasperFx,项目名称:marten,代码行数:7,代码来源:SequenceFactory.cs
示例18: ComposeConnectionFactory
private static void ComposeConnectionFactory()
{
try
{
using (var catalog = new DirectoryCatalog(AppDomain.CurrentDomain.BaseDirectory))
using (var container = new CompositionContainer(catalog))
{
var export = container.GetExportedValueOrDefault<IConnectionFactory>();
if (export != null)
{
Factory = export;
Console.WriteLine("Using {0}", Factory.GetType());
}
}
}
catch (ImportCardinalityMismatchException)
{
Console.WriteLine("More than one IConnectionFactory import was found.");
}
catch (Exception e)
{
Console.WriteLine(e);
}
if (Factory == null)
{
Factory = new DefaultConnectionFactory();
Console.WriteLine("Using default connection factory...");
}
}
开发者ID:ZixiangBoy,项目名称:SignalR-1,代码行数:30,代码来源:Client.cs
示例19: Repository
public Repository(
IConnectionFactory connectionFactory,
IConfigurationStore configurationStore)
{
_connectionFactory = connectionFactory;
_configurationStore = configurationStore;
}
开发者ID:Bikeman868,项目名称:Prius,代码行数:7,代码来源:Repository.cs
示例20: Render
public String Render(IList<Object> args, IConnectionFactory factory)
{
if (args.Count != 2)
throw new MappingException("cast() requires two arguments");
return "cast(" + args[0] + " as " + factory.Dialect.GetCastTypeName((String)args[1]) + ')';
}
开发者ID:wyerp,项目名称:EasyDb.NET,代码行数:7,代码来源:CastFunction.cs
注:本文中的IConnectionFactory类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论