Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

fixing compilation errors

  • Loading branch information...
commit 5cb91d91d34d8552e54fa577121676098b7f3b10 1 parent abfdade
@clebertsuconic clebertsuconic authored
Showing with 6 additions and 31 deletions.
  1. +6 −31 src/main/org/hornetq/ra/HornetQResourceAdapter.java
View
37 src/main/org/hornetq/ra/HornetQResourceAdapter.java
@@ -1196,35 +1196,6 @@ public void setUseLocalTx(final Boolean localTx)
raProperties.setUseLocalTx(localTx);
}
- /**
- * Get the use XA flag
- *
- * @return The value
- */
- public Boolean getUseXA()
- {
- if (HornetQResourceAdapter.trace)
- {
- HornetQResourceAdapter.log.trace("getUseXA()");
- }
-
- return raProperties.getUseXA();
- }
-
- /**
- * Set the use XA flag
- *
- * @param xa The value
- */
- public void setUseXA(final Boolean xa)
- {
- if (HornetQResourceAdapter.trace)
- {
- HornetQResourceAdapter.log.trace("setUseXA(" + xa + ")");
- }
-
- raProperties.setUseXA(xa);
- }
/**
* Indicates whether some other object is "equal to" this one.
@@ -1368,10 +1339,13 @@ protected HornetQRAProperties getProperties()
*/
protected void setup() throws HornetQException
{
+
+
defaultHornetQConnectionFactory = createHornetQConnectionFactory(raProperties);
sessionFactory = defaultHornetQConnectionFactory.getCoreFactory();
}
+
public HornetQConnectionFactory getDefaultHornetQConnectionFactory() throws ResourceException
{
if (!configured.getAndSet(true))
@@ -1410,13 +1384,13 @@ public HornetQConnectionFactory createHornetQConnectionFactory(final ConnectionF
: new TransportConfiguration(backUpCOnnectorClassname,
backupConnectionParams);
- cf = (HornetQConnectionFactory) HornetQJMSClient.createConnectionFactory(transportConf, backup);
+ cf = HornetQJMSClient.createConnectionFactory(transportConf, backup);
}
else if (discoveryAddress != null)
{
Integer discoveryPort = overrideProperties.getDiscoveryPort() != null ? overrideProperties.getDiscoveryPort()
: getDiscoveryPort();
- cf = (HornetQConnectionFactory) HornetQJMSClient.createConnectionFactory(discoveryAddress, discoveryPort);
+ cf = HornetQJMSClient.createConnectionFactory(discoveryAddress, discoveryPort);
}
else
{
@@ -1425,6 +1399,7 @@ else if (discoveryAddress != null)
setParams(cf, overrideProperties);
return cf;
}
+
public Map<String, Object> overrideConnectionParameters(final Map<String, Object> connectionParams,
final Map<String, Object> overrideConnectionParams)
{
Please sign in to comment.
Something went wrong with that request. Please try again.